org.apache.flink.streaming.api.operators

Interface OneInputStreamOperator<IN,OUT>

Type Parameters:

IN - The input type of the operator

OUT - The output type of the operator

All Superinterfaces:

CheckpointListener, Disposable, KeyContext, Serializable, StreamOperator<OUT>

All Known Implementing Classes:

AbstractMapBundleOperator, AbstractPythonFunctionOperator, AbstractPythonScalarFunctionOperator, AbstractPythonTableFunctionOperator, AbstractRowDataPythonScalarFunctionOperator, AbstractRowPythonScalarFunctionOperator, AbstractStatelessFunctionOperator, AggregateWindowOperator, ArrowPythonScalarFunctionOperator, AsyncWaitOperator, BroadcastStateBootstrapOperator, BufferDataOverWindowOperator, CassandraRowWriteAheadSink, CassandraTupleWriteAheadSink, CepOperator, CollectSinkOperator, ContinuousFileReaderOperator, EvictingWindowOperator, GenericWriteAheadSink, KeyedMapBundleOperator, KeyedProcessOperator, KeyedStateBootstrapOperator, LegacyKeyedProcessOperator, LimitOperator, MapBundleOperator, NonBufferOverWindowOperator, ProcessOperator, ProcTimeMiniBatchAssignerOperator, ProcTimeSortOperator, PythonScalarFunctionOperator, PythonTableFunctionOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, RankOperator, RowDataArrowPythonScalarFunctionOperator, RowDataPythonScalarFunctionOperator, RowDataPythonTableFunctionOperator, RowTimeMiniBatchAssginerOperator, RowTimeSortOperator, SinkOperator, SortLimitOperator, SortOperator, StateBootstrapOperator, StreamFilter, StreamFlatMap, StreamGroupedFold, StreamGroupedReduce, StreamingFileCommitter, StreamingFileWriter, StreamMap, StreamProject, StreamSink, StreamSortOperator, TableAggregateWindowOperator, TimestampsAndWatermarksOperator, WatermarkAssignerOperator, WindowOperator, WindowOperator

@PublicEvolving
public interface OneInputStreamOperator<IN,OUT>
extends StreamOperator<OUT>

Interface for stream operators with one input. Use AbstractStreamOperator as a base class if you want to implement a custom operator.

Method Summary

Modifier and Type	Method and Description
void	processElement(StreamRecord<IN> element) Processes one element that arrived at this operator.
void	processLatencyMarker(LatencyMarker latencyMarker)
void	processWatermark(Watermark mark) Processes a Watermark.

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

close, dispose, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

Methods inherited from interface org.apache.flink.runtime.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

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

getCurrentKey, setCurrentKey

Method Detail

processElement

void processElement(StreamRecord<IN> element)
             throws Exception

Processes one element that arrived at this operator. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

processWatermark

void processWatermark(Watermark mark)
               throws Exception

Processes a Watermark. This method is guaranteed to not be called concurrently with other methods of the operator.

Throws:

Exception

See Also:

Watermark

processLatencyMarker

void processLatencyMarker(LatencyMarker latencyMarker)
                   throws Exception

Throws:

Exception