Sure Sir. I'll put up a feature request.

On Sat, Apr 8, 2017 at 1:13 AM, Yogi Devendra <[email protected]>
wrote:

> 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.
>>>>
>>>
>>>
>>
>

Reply via email to