Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Implemented
-
None
-
None
Description
Currently, AbstractFileInputOperator advances the streaming window if the data in the window reaches a preset batch size. We should allow subclasses to have other means to advance the window.