Hi, 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 ? Regards JB On 28/05/2018 17:29, maxime.dej...@orange.com 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é jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com
