@PublicEvolving public interface BoundedMultiInput
NOTE: Classes should not implement both
BoundedMultiInput at the same time!
|Modifier and Type||Method and Description|
It is notified that no more data will arrive from the input identified by the
void endInput(int inputId) throws Exception
inputIdis numbered starting from 1, and `1` indicates the first input.
WARNING: It is not safe to use this method to commit any transactions or other side
effects! You can use this method to e.g. flush data buffered for the given input or implement
an ordered reading from multiple inputs via
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.