org.apache.flink.streaming.runtime.tasks

Class StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.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:

org.apache.flink.runtime.jobgraph.tasks.StoppableTask, AsyncExceptionHandler

public class StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.StoppableFunction>
extends SourceStreamTask<OUT,SRC,StoppableStreamSource<OUT,SRC>>
implements org.apache.flink.runtime.jobgraph.tasks.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(org.apache.flink.runtime.execution.Environment environment)

Method Summary

Modifier and Type	Method and Description
protected void	run()
void	stop()

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

Methods inherited from class java.lang.Object

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

Constructor Detail

StoppableSourceStreamTask

public StoppableSourceStreamTask(org.apache.flink.runtime.execution.Environment environment)

Method Detail

run

protected void run()
            throws Exception

Overrides:

run in class SourceStreamTask<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.StoppableFunction,StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & org.apache.flink.api.common.functions.StoppableFunction>>

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface org.apache.flink.runtime.jobgraph.tasks.StoppableTask