public abstract class InputBase extends Object implements Input<RowData>
Input
used in MultipleInputStreamOperatorBase
.Constructor and Description |
---|
InputBase() |
Modifier and Type | Method and Description |
---|---|
void |
setKeyContextElement(StreamRecord<RowData> record)
Set the correct key context before processing the
record . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processElement, processLatencyMarker, processWatermark, processWatermarkStatus
public void setKeyContextElement(StreamRecord<RowData> record) throws Exception
Input
record
. Used for example to extract
key from the record
and pass that key to the state backends. This method is
guaranteed to not be called concurrently with other methods of the operator.setKeyContextElement
in interface Input<RowData>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.