@Internal public class StreamIterationTail<IN> extends OneInputStreamTask<IN,IN>
headOperator, TRIGGER_THREAD_GROUP
Constructor and Description |
---|
StreamIterationTail() |
Modifier and Type | Method and Description |
---|---|
void |
init() |
cancelTask, cleanup, run
cancel, checkTimerException, createStateBackend, finalize, getAccumulatorMap, getCheckpointBarrierListener, getCheckpointLock, getConfiguration, getHeadOutput, getName, getStreamOutputs, invoke, isCanceled, isRunning, isSerializingTimestamps, notifyCheckpointComplete, performCheckpoint, registerTimer, setInitialState, toString, triggerCheckpoint
getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.