Kx Systems aka Q or KDB
-Original Message-
From: Yi Pan [mailto:nickpa...@gmail.com]
Sent: 06 September 2016 17:40
To: dev@samza.apache.org
Subject: Re: checkpoint on flush of system producer
Hi, Jarrad,
Yes! You have found your answer! Looking forward to your implementation of
'process' of StreamTask).
>
> -----Original Message-
> From: Jarrad, Ken [ICG-IT]
> Sent: 06 September 2016 14:55
> To: 'dev@samza.apache.org'
> Subject: checkpoint on flush of system producer
>
> I am writing a SystemProducer and I would be gratefu
ask).
-Original Message-
From: Jarrad, Ken [ICG-IT]
Sent: 06 September 2016 14:55
To: 'dev@samza.apache.org'
Subject: checkpoint on flush of system producer
I am writing a SystemProducer and I would be grateful for any comments or
documentation.
I want my SystemProducer to
I am writing a SystemProducer and I would be grateful for any comments or
documentation.
I want my SystemProducer to collect messages until flush is invoked.
That is, I don't want to transmit each message 'one by one'.
I want to wait until flush is invoked and then transmit 'in bulk'.
I don't kn
