@PublicEvolving public interface BoundedOneInput
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.
void endInput() throws Exception
WARNING: It is not safe to use this method to commit any transactions or other side
effects! You can use this method to flush any buffered data that can later on be committed
e.g. in a
NOTE: Given it is semantically very similar to the
method. It might be dropped in favour of the other method at some point in time.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.