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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processElement, processLatencyMarker, processWatermark
public void setKeyContextElement(StreamRecord<RowData> record) throws Exception
setKeyContextElement
in interface Input<RowData>
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.