IN
- The input type of the operatorOUT
- The output type of the operator@PublicEvolving public interface OneInputStreamOperator<IN,OUT> extends StreamOperator<OUT>, Input<IN>
AbstractStreamOperator
as a base class if you want to
implement a custom operator.Modifier and Type | Method and Description |
---|---|
default void |
setKeyContextElement(StreamRecord<IN> record) |
close, dispose, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
processElement, processLatencyMarker, processWatermark
default void setKeyContextElement(StreamRecord<IN> record) throws Exception
setKeyContextElement
in interface Input<IN>
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.