org.apache.flink.streaming.runtime.tasks

Class OneInputStreamTask<IN,OUT>

java.lang.Object

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

org.apache.flink.streaming.runtime.tasks.StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

org.apache.flink.streaming.runtime.tasks.OneInputStreamTask<IN,OUT>

All Implemented Interfaces:

AsyncExceptionHandler

Direct Known Subclasses:

StreamIterationHead, StreamIterationTail

@Internal
public class OneInputStreamTask<IN,OUT>
extends StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

A StreamTask for executing a OneInputStreamOperator.

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
OneInputStreamTask(org.apache.flink.runtime.execution.Environment env) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
OneInputStreamTask(org.apache.flink.runtime.execution.Environment env, ProcessingTimeService timeProvider) 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

OneInputStreamTask

public OneInputStreamTask(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.

OneInputStreamTask

@VisibleForTesting
public OneInputStreamTask(org.apache.flink.runtime.execution.Environment env,
                                             @Nullable
                                             ProcessingTimeService timeProvider)

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

This constructor accepts a special ProcessingTimeService. By default (and if null is passes for the time provider) a DefaultTimerService will be used.

Parameters:

env - The task environment for this task.

timeProvider - Optionally, a specific time provider to use.

Method Detail

init

public void init()
          throws Exception

Specified by:

init in class StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

Throws:

Exception

run

protected void run()
            throws Exception

Specified by:

run in class StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

Throws:

Exception

cleanup

protected void cleanup()
                throws Exception

Specified by:

cleanup in class StreamTask<OUT,OneInputStreamOperator<IN,OUT>>

Throws:

Exception

cancelTask

protected void cancelTask()

Specified by:

cancelTask in class StreamTask<OUT,OneInputStreamOperator<IN,OUT>>