You can set emitBatchSize to 1 and make sure emitTuples is called just 'x' times within a window. You can do this manually by keeping a count and resetting it in beginWindow().
~ Bhupesh _______________________________________________________ Bhupesh Chawda E: [email protected] | Twitter: @bhupeshsc www.datatorrent.com | apex.apache.org On Fri, Apr 7, 2017 at 1:38 PM, Ambarish Pande <[email protected] > wrote: > Yes i tried. That just gives me control on how many times emitTuples is > called. I want control on number of tuples emitted. > > Thank you. > > Sent from my iPhone > > On 07-Apr-2017, at 8:08 AM, Yogi Devendra <[email protected]> > wrote: > > Have you tried *emitBatchSize *as mentioned https://apex.apache. > org/docs/malhar/operators/fsInputOperator/ > > ~ Yogi > > On 3 April 2017 at 00:05, Ambarish Pande <[email protected]> > 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. >> > >
