IN
- The input type of the operatorOUT
- The output type of the operator@PublicEvolving public interface OneInputStreamOperator<IN,OUT> extends StreamOperator<OUT>
AbstractStreamOperator
as a base class if
you want to implement a custom operator.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 . |
close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, notifyOfCompletedCheckpoint, open, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotState
void processElement(StreamRecord<IN> element) throws Exception
Exception
void processWatermark(Watermark mark) throws Exception
Watermark
.
This method is guaranteed to not be called concurrently with other methods of the operator.void processLatencyMarker(LatencyMarker latencyMarker) throws Exception
Exception
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.