org.apache.flink.streaming.runtime.tasks

Class StreamIterationHead<OUT>

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

org.apache.flink.streaming.runtime.tasks.StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

org.apache.flink.streaming.runtime.tasks.OneInputStreamTask<OUT,OUT>

org.apache.flink.streaming.runtime.tasks.StreamIterationHead<OUT>

All Implemented Interfaces:

AsyncExceptionHandler

@Internal
public class StreamIterationHead<OUT>
extends OneInputStreamTask<OUT,OUT>

A special StreamTask that is used for executing feedback edges. This is used in combination with StreamIterationTail.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

StreamTask.AsyncCheckpointRunnable

Field Summary

Fields inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

configuration, headOperator, operatorChain, stateBackend, timerService, TRIGGER_THREAD_GROUP

Constructor Summary

Constructors

Constructor and Description
StreamIterationHead(org.apache.flink.runtime.execution.Environment env)

Method Summary

Modifier and Type	Method and Description
protected void	cancelTask()
protected void	cleanup()
static String	createBrokerIdString(org.apache.flink.api.common.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()

Methods inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

abortCheckpointOnBarrier, cancel, createCheckpointExceptionHandlerFactory, createStreamRecordWriters, createStreamTaskStateInitializer, finalize, getAccumulatorMap, getAsyncOperationsThreadPool, getCancelables, getCheckpointLock, getCheckpointStorage, getConfiguration, getName, getProcessingTimeService, getStreamStatusMaintainer, handleAsyncException, invoke, isCanceled, isRunning, notifyCheckpointComplete, toString, triggerCheckpoint, triggerCheckpointOnBarrier

Methods inherited from class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setShouldInterruptOnCancel, shouldInterruptOnCancel

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamIterationHead

public StreamIterationHead(org.apache.flink.runtime.execution.Environment env)

Method Detail

run

protected void run()
            throws Exception

Overrides:

run in class OneInputStreamTask<OUT,OUT>

Throws:

Exception

cancelTask

protected void cancelTask()

Overrides:

cancelTask in class OneInputStreamTask<OUT,OUT>

init

public void init()

Overrides:

init in class OneInputStreamTask<OUT,OUT>

cleanup

protected void cleanup()
                throws Exception

Overrides:

cleanup in class OneInputStreamTask<OUT,OUT>

Throws:

Exception

createBrokerIdString

public static String createBrokerIdString(org.apache.flink.api.common.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. The identification string is unique per parallel head/tail pair per iteration per job.

Parameters:

jid - The job ID.

iterationID - The id of the iteration in the job.

subtaskIndex - The parallel subtask number

Returns:

The identification string.