org.apache.flink.streaming.runtime.tasks

Class TwoInputStreamTask<IN1,IN2,OUT>

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

org.apache.flink.streaming.runtime.tasks.StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>

org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask<IN1,IN2,OUT>

All Implemented Interfaces:

AsyncExceptionHandler

@Internal
public class TwoInputStreamTask<IN1,IN2,OUT>
extends StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>

A StreamTask for executing a TwoInputStreamOperator.

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
TwoInputStreamTask(Environment env) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).

Method Summary

Modifier and Type	Method and Description
protected void	cancelTask()
protected void	cleanup()
void	init()
protected void	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

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TwoInputStreamTask

public TwoInputStreamTask(Environment env)

Constructor for initialization, possibly with initial state (recovery / savepoint / etc).

Parameters:

env - The task environment for this task.

Method Detail

init

public void init()
          throws Exception

Specified by:

init in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>

Throws:

Exception

run

protected void run()
            throws Exception

Specified by:

run in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>

Throws:

Exception

cleanup

protected void cleanup()
                throws Exception

Specified by:

cleanup in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>

Throws:

Exception

cancelTask

protected void cancelTask()

Specified by:

cancelTask in class StreamTask<OUT,TwoInputStreamOperator<IN1,IN2,OUT>>