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 |
processWatermark(Watermark mark)
Processes a
Watermark . |
close, dispose, getChainingStrategy, isInputCopyingDisabled, notifyOfCompletedCheckpoint, open, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
void processElement(StreamRecord<IN> element) throws Exception
Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.