Ambarish, What you are asking for would be useful for others as well.
Would you mind contributing this change to the community? If you are interested, please create JIRA on https://issues.apache.org/jira/browse/APEXMALHAR for your request. For any dev discussions, please use dev@apex mailing list. ~ Yogi On 7 April 2017 at 01:14, Bhupesh Chawda <[email protected]> wrote: > 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. >>> >> >> >
