org.apache.flink.streaming.runtime.tasks

Class StreamIterationTail<IN>

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<IN,IN>

org.apache.flink.streaming.runtime.tasks.StreamIterationTail<IN>

All Implemented Interfaces:

AsyncExceptionHandler

@Internal
public class StreamIterationTail<IN>
extends OneInputStreamTask<IN,IN>

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

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
StreamIterationTail(org.apache.flink.runtime.execution.Environment environment)

Method Summary

Modifier and Type	Method and Description
void	init()

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

cancelTask, cleanup, 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

StreamIterationTail

public StreamIterationTail(org.apache.flink.runtime.execution.Environment environment)

Method Detail

init

public void init()
          throws Exception

Overrides:

init in class OneInputStreamTask<IN,IN>

Throws:

Exception