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