@Internal public class TwoInputStreamTask<IN1,IN2,OUT> extends StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>
headOperator, TRIGGER_THREAD_GROUP
Constructor and Description |
---|
TwoInputStreamTask() |
Modifier and Type | Method and Description |
---|---|
protected void |
cancelTask() |
protected void |
cleanup() |
void |
init() |
protected void |
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
public void init() throws Exception
init
in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>
Exception
protected void run() throws Exception
run
in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>
Exception
protected void cleanup() throws Exception
cleanup
in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>
Exception
protected void cancelTask()
cancelTask
in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.