@PublicEvolving public interface BoundedOneInput
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
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.