org.apache.flink.streaming.api.operators

Class StreamSource<OUT,SRC extends SourceFunction<OUT>>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,SRC>

org.apache.flink.streaming.api.operators.StreamSource<OUT,SRC>

Type Parameters:

OUT - Type of the output elements

SRC - Type of the source function of this stream source operator

All Implemented Interfaces:

Serializable, KeyContext, OutputTypeConfigurable<OUT>, StreamOperator<OUT>

Direct Known Subclasses:

StoppableStreamSource

@Internal
public class StreamSource<OUT,SRC extends SourceFunction<OUT>>
extends AbstractUdfStreamOperator<OUT,SRC>
implements StreamOperator<OUT>

StreamOperator for streaming sources.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

AbstractStreamOperator.CountingOutput, AbstractStreamOperator.LatencyGauge

Field Summary

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator

userFunction

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

chainingStrategy, config, latencyGauge, LOG, metrics, output, timeServiceManager

Constructor Summary

Constructors

Constructor and Description
StreamSource(SRC sourceFunction)

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected boolean	isCanceledOrStopped() Checks whether the source has been canceled or stopped.
protected void	markCanceledOrStopped() Marks this source as canceled or stopped.
void	run(Object lockingObject, StreamStatusMaintainer streamStatusMaintainer)
void	run(Object lockingObject, StreamStatusMaintainer streamStatusMaintainer, Output<StreamRecord<OUT>> collector)

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator

close, dispose, getUserFunction, getUserFunctionParameters, initializeState, notifyOfCompletedCheckpoint, open, setOutputType, setup, snapshotState

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, notifyOfCompletedCheckpoint, open, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState

Constructor Detail

StreamSource

public StreamSource(SRC sourceFunction)

Method Detail

run

public void run(Object lockingObject,
                StreamStatusMaintainer streamStatusMaintainer)
         throws Exception

Throws:

Exception

run

public void run(Object lockingObject,
                StreamStatusMaintainer streamStatusMaintainer,
                Output<StreamRecord<OUT>> collector)
         throws Exception

Throws:

Exception

cancel

public void cancel()

markCanceledOrStopped

protected void markCanceledOrStopped()

Marks this source as canceled or stopped.

This indicates that any exit of the run(Object, StreamStatusMaintainer, Output) method cannot be interpreted as the result of a finite source.

isCanceledOrStopped

protected boolean isCanceledOrStopped()

Checks whether the source has been canceled or stopped.

Returns:

True, if the source is canceled or stopped, false is not.