org.apache.flink.streaming.runtime.tasks

Class StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>

java.lang.Object

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

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

org.apache.flink.streaming.runtime.tasks.SourceStreamTask<OUT,SRC,StoppableStreamSource<OUT,SRC>>

org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask<OUT,SRC>

Type Parameters:

OUT - Type of the produced elements

SRC - Stoppable source function

All Implemented Interfaces:

StoppableTask, AsyncExceptionHandler

public class StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>
extends SourceStreamTask<OUT,SRC,StoppableStreamSource<OUT,SRC>>
implements StoppableTask

Stoppable task for executing stoppable streaming sources.

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
StoppableSourceStreamTask(Environment environment)

Method Summary

Modifier and Type	Method and Description
protected void	run()
void	stop() Called on STOP signal.

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

cancelTask, cleanup, init, triggerCheckpoint

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, 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

StoppableSourceStreamTask

public StoppableSourceStreamTask(Environment environment)

Method Detail

run

protected void run()
            throws Exception

Overrides:

run in class SourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction,StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>>

Throws:

Exception

stop

public void stop()

Description copied from interface: StoppableTask

Called on STOP signal.

Specified by:

stop in interface StoppableTask