org.apache.flink.streaming.api.operators

接口 OneInputStreamOperator<IN,OUT>

类型参数:

IN - The input type of the operator

OUT - The output type of the operator

所有超级接口:

org.apache.flink.api.common.state.CheckpointListener, Input<IN>, KeyContext, Serializable, StreamOperator<OUT>

所有已知实现类:

AsyncWaitOperator, BatchGroupedReduceOperator, CollectSinkOperator, ContinuousFileReaderOperator, EvictingWindowOperator, GenericWriteAheadSink, KeyedProcessOperator, LegacyKeyedProcessOperator, ProcessOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, StreamFilter, StreamFlatMap, StreamGroupedReduceOperator, StreamMap, StreamProject, StreamSink, TimestampsAndWatermarksOperator, WindowOperator

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

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

方法概要

限定符和类型	方法和说明
default void	setKeyContextElement(StreamRecord<IN> record)

从接口继承的方法 org.apache.flink.streaming.api.operators.StreamOperator

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

从接口继承的方法 org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

从接口继承的方法 org.apache.flink.streaming.api.operators.KeyContext

getCurrentKey, setCurrentKey

从接口继承的方法 org.apache.flink.streaming.api.operators.Input

processElement, processLatencyMarker, processWatermark, processWatermarkStatus

方法详细资料

setKeyContextElement

default void setKeyContextElement(StreamRecord<IN> record)
                           throws Exception

指定者:

setKeyContextElement 在接口中 Input<IN>

抛出:

Exception