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(org.apache.flink.runtime.execution.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, setShouldInterruptOnCancel, shouldInterruptOnCancel

Methods inherited from class java.lang.Object

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

Constructor Detail

TwoInputStreamTask

public TwoInputStreamTask(org.apache.flink.runtime.execution.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>>