[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: How to process data


I guess you want to process based on the watermark or the timestamp
(event time/processing time).

You can take a look on beam-samples to create window after watermark.

What kind of use case you want to implement ?


On 28/05/2018 17:29, maxime.dejeux@xxxxxxxxxx wrote:
> Hello, I want to process data, which comes from Kafka, with a process
> “Event time” but I haven’t found the code for doing this in the
> documentation.
> Could you give me some information.
> Thank you in advance,
> Maxime Dejeux
> _________________________________________________________________________________________________________________________
> Ce message et ses pieces jointes peuvent contenir des informations confidentielles ou privilegiees et ne doivent donc
> pas etre diffuses, exploites ou copies sans autorisation. Si vous avez recu ce message par erreur, veuillez le signaler
> a l'expediteur et le detruire ainsi que les pieces jointes. Les messages electroniques etant susceptibles d'alteration,
> Orange decline toute responsabilite si ce message a ete altere, deforme ou falsifie. Merci.
> This message and its attachments may contain confidential or privileged information that may be protected by law;
> they should not be distributed, used or copied without authorisation.
> If you have received this email in error, please notify the sender and delete this message and its attachments.
> As emails may be altered, Orange is not liable for messages that have been modified, changed or falsified.
> Thank you.

Jean-Baptiste Onofré
Talend -