Have you tried *emitBatchSize *as mentioned https://apex.apache.org/docs/malhar/operators/fsInputOperator/
~ Yogi On 3 April 2017 at 00:05, Ambarish Pande <ambarish.pande2...@gmail.com> wrote: > Hi, > > How can i make the AbstractFileInputOperator emit only 'x' number of lines > per window. Is there a hook for that. Or i have to do it manually? > > Thank You. >
