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, java.lang.String 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 packedPlan, java.lang.String componentRamMap)

Method Summary

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

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,
                                 java.lang.String 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 packedPlan,
                                 java.lang.String componentRamMap)

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