org.apache.flink.streaming.runtime.tasks

Class AbstractTwoInputStreamTask<IN1,IN2,OUT>

java.lang.Object

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

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

All Implemented Interfaces:

CheckpointableTask, CoordinatedTask, TaskInvokable, AsyncExceptionHandler, ContainingTaskDetails

Direct Known Subclasses:

TwoInputStreamTask

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

Abstract class for executing a TwoInputStreamOperator.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

StreamTask.CanEmitBatchOfRecordsChecker

Field Summary

Fields

Modifier and Type	Field and Description
protected WatermarkGauge	input1WatermarkGauge
protected WatermarkGauge	input2WatermarkGauge
protected MinWatermarkGauge	minInputWatermarkGauge

Fields inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

checkpointStorage, configuration, inputProcessor, LOG, mailboxProcessor, mainOperator, operatorChain, recordWriter, stateBackend, systemTimerService, timerService, TRIGGER_THREAD_GROUP

Constructor Summary

Constructors

Constructor and Description
AbstractTwoInputStreamTask(Environment env) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).

Method Summary

Modifier and Type	Method and Description
protected abstract void	createInputProcessor(List<IndexedInputGate> inputGates1, List<IndexedInputGate> inputGates2, Function<Integer,StreamPartitioner<?>> gatePartitioners)
void	init()

Methods inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

abortCheckpointOnBarrier, advanceToEndOfEventTime, afterInvoke, cancel, cancelTask, cleanUp, cleanUpInternal, createRecordWriterDelegate, createStreamTaskStateInitializer, declineCheckpoint, dispatchOperatorEvent, endData, finalize, getAsyncCheckpointStartDelayNanos, getAsyncOperationsThreadPool, getCancelables, getCanEmitBatchOfRecords, getCheckpointBarrierHandler, getCheckpointStorage, getCompletionFuture, getConfiguration, getEnvironment, getMailboxExecutorFactory, getName, getProcessingTimeServiceFactory, handleAsyncException, hasMail, invoke, isCanceled, isFailing, isMailboxLoopRunning, isRunning, isUsingNonBlockingInput, maybeInterruptOnCancel, notifyCheckpointAbortAsync, notifyCheckpointCompleteAsync, notifyCheckpointSubsumedAsync, notifyEndOfData, processInput, restore, runMailboxLoop, runMailboxStep, runSingleMailboxLoop, setSynchronousSavepoint, setupNumRecordsInCounter, toString, triggerCheckpointAsync, triggerCheckpointOnBarrier

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.runtime.tasks.ContainingTaskDetails

getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getUserCodeClassLoader

Field Detail

input1WatermarkGauge

protected final WatermarkGauge input1WatermarkGauge

input2WatermarkGauge

protected final WatermarkGauge input2WatermarkGauge

minInputWatermarkGauge

protected final MinWatermarkGauge minInputWatermarkGauge

Constructor Detail

AbstractTwoInputStreamTask

public AbstractTwoInputStreamTask(Environment env)
                           throws Exception

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

Parameters:

env - The task environment for this task.

Throws:

Exception

Method Detail

init

public void init()
          throws Exception

Specified by:

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

Throws:

Exception

createInputProcessor

protected abstract void createInputProcessor(List<IndexedInputGate> inputGates1,
                                             List<IndexedInputGate> inputGates2,
                                             Function<Integer,StreamPartitioner<?>> gatePartitioners)
                                      throws Exception

Throws:

Exception