It signifies how many tuples to emit in one shot before returning control. There can be multiple such calls within a window.
On Thu, Nov 5, 2015 at 12:52 PM, Timothy Farkas <[email protected]> wrote: > I believe it's the latter. > > Tim > > On Thu, Nov 5, 2015 at 12:50 PM, Chandni Singh <[email protected]> > wrote: > > > Hi, > > > > Does the emitBatchSize in AbstractFileInputOperator signify that only > > specified number of tuples will be emitted in an operator's application > > window? > > > > If the answer to above is 'yes' then there is a bug in the code because > > emitTuples() can be called multiple times within an app window. > > > > If not and it signifies how many tuples to emit in emitWindow() then > > everything is great :) > > > > Chandni > > >
