@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
abortCheckpointOnBarrier, cancel, createCheckpointStreamFactory, createKeyedStateBackend, createOperatorStateBackend, finalize, getAccumulatorMap, getAsyncOperationsThreadPool, getCancelables, getCheckpointLock, getConfiguration, getName, getProcessingTimeService, handleAsyncException, invoke, isCanceled, isRunning, notifyCheckpointComplete, setInitialState, setProcessingTimeService, toString, triggerCheckpoint, triggerCheckpointOnBarrier
getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.