OUT
- Type of the output elementsSRC
- Type of the source function which has to be stoppablepublic class StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction> extends StreamSource<OUT,SRC>
StreamSource.AutomaticWatermarkContext<T>, StreamSource.ManualWatermarkContext<T>, StreamSource.NonTimestampContext<T>
AbstractStreamOperator.CountingOutput
userFunction
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
StoppableStreamSource(SRC sourceFunction)
Takes a
SourceFunction that implements StoppableFunction . |
Modifier and Type | Method and Description |
---|---|
void |
stop()
Marks the source a stopped and calls
StoppableFunction.stop() on the user function. |
cancel, checkAsyncException, isCanceledOrStopped, markCanceledOrStopped, run, run
close, dispose, getUserFunction, getUserFunctionParameters, notifyOfCompletedCheckpoint, open, restoreState, setOutputType, setup, snapshotOperatorState
getChainingStrategy, getContainingTask, getCurrentProcessingTime, getExecutionConfig, getMetricGroup, getOperatorConfig, getOperatorName, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, registerTimer, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, dispose, getChainingStrategy, getMetricGroup, notifyOfCompletedCheckpoint, open, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
public StoppableStreamSource(SRC sourceFunction)
SourceFunction
that implements StoppableFunction
.sourceFunction
- A SourceFunction
that implements StoppableFunction
.public void stop()
StoppableFunction.stop()
on the user function.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.