OUT
- Type of the produced elementsSRC
- Stoppable source functionpublic class StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction> extends SourceStreamTask<OUT,SRC,StoppableStreamSource<OUT,SRC>> implements StoppableTask
headOperator, LOG, TRIGGER_THREAD_GROUP
Constructor and Description |
---|
StoppableSourceStreamTask() |
Modifier and Type | Method and Description |
---|---|
void |
stop()
Called on STOP signal.
|
cancelTask, cleanup, init, run
cancel, checkTimerException, createStateBackend, finalize, getAccumulatorMap, getCheckpointBarrierListener, getCheckpointLock, getConfiguration, getHeadOutput, getName, getStreamOutputs, invoke, isCanceled, isRunning, isSerializingTimestamps, notifyCheckpointComplete, performCheckpoint, registerTimer, setInitialState, toString, triggerCheckpoint
getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment
public void stop()
StoppableTask
stop
in interface StoppableTask
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.