@Internal public class StreamIterationHead<OUT> extends OneInputStreamTask<OUT,OUT>
StreamTask
that is used for executing feedback edges. This is used in
combination with StreamIterationTail
.headOperator, operatorChain, TRIGGER_THREAD_GROUP
Constructor and Description |
---|
StreamIterationHead() |
Modifier and Type | Method and Description |
---|---|
protected void |
cancelTask() |
protected void |
cleanup() |
static String |
createBrokerIdString(JobID jid,
String iterationID,
int subtaskIndex)
Creates the identification string with which head and tail task find the shared blocking
queue for the back channel.
|
void |
init() |
protected void |
run() |
abortCheckpointOnBarrier, cancel, createCheckpointStreamFactory, createKeyedStateBackend, createOperatorStateBackend, createSavepointStreamFactory, finalize, getAccumulatorMap, getAsyncOperationsThreadPool, getCancelables, getCheckpointLock, getConfiguration, getName, getProcessingTimeService, getStreamStatusMaintainer, handleAsyncException, invoke, isCanceled, isRunning, notifyCheckpointComplete, setInitialState, setProcessingTimeService, toString, triggerCheckpoint, triggerCheckpointOnBarrier
getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment
protected void run() throws Exception
run
in class OneInputStreamTask<OUT,OUT>
Exception
protected void cancelTask()
cancelTask
in class OneInputStreamTask<OUT,OUT>
public void init()
init
in class OneInputStreamTask<OUT,OUT>
protected void cleanup() throws Exception
cleanup
in class OneInputStreamTask<OUT,OUT>
Exception
public static String createBrokerIdString(JobID jid, String iterationID, int subtaskIndex)
jid
- The job ID.iterationID
- The id of the iteration in the job.subtaskIndex
- The parallel subtask numberCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.