com.twitter.heron.scheduler.yarn

Class HeronExecutorTask

java.lang.Object

com.twitter.heron.scheduler.yarn.HeronExecutorTask

All Implemented Interfaces:

org.apache.reef.task.Task

public class HeronExecutorTask
extends java.lang.Object
implements org.apache.reef.task.Task

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HeronExecutorTask.HeronExecutorTaskTerminator This class will kill heron executor process when topology or container restart is requested.

Constructor Summary

Constructors

Constructor and Description
HeronExecutorTask(org.apache.reef.runtime.common.files.REEFFileNames fileNames, int heronExecutorId, java.lang.String cluster, java.lang.String role, java.lang.String topologyName, java.lang.String env, java.lang.String topologyPackageName, java.lang.String heronCorePackageName, java.lang.String topologyJar, java.lang.String componentRamMap, boolean verboseMode)

Method Summary

Modifier and Type	Method and Description
byte[]	call(byte[] memento)
void	startExecutor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HeronExecutorTask

@Inject
public HeronExecutorTask(org.apache.reef.runtime.common.files.REEFFileNames fileNames,
                                 int heronExecutorId,
                                 java.lang.String cluster,
                                 java.lang.String role,
                                 java.lang.String topologyName,
                                 java.lang.String env,
                                 java.lang.String topologyPackageName,
                                 java.lang.String heronCorePackageName,
                                 java.lang.String topologyJar,
                                 java.lang.String componentRamMap,
                                 boolean verboseMode)

Method Detail

call

public byte[] call(byte[] memento)
            throws java.lang.Exception

Specified by:

call in interface org.apache.reef.task.Task

Throws:

java.lang.Exception

startExecutor

public void startExecutor()