@PublicEvolving public interface MultipleInputStreamOperator<OUT> extends StreamOperator<OUT>
Input
s.Modifier and Type | Method and Description |
---|---|
List<Input> |
getInputs() |
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.