Re: [FEEDBACK] Metadata Platforms / Catalogs / Lineage integration

2022-01-13 Thread Pedro Silva
Hello, I'm part of the DataHub community and working in collaboration with the company behind it: http://acryldata.io Happy to have a conversation or clarify any questions you may have on DataHub :) Have a nice day! Em qui., 13 de jan. de 2022 às 15:33, Andrew Otto escreveu: > Hello! The

Re: CEP library support in Python

2021-09-15 Thread Pedro Silva
e. It > can be solved with a simple process function that tracks the state for each > id. Output a 1 when a job completes and a -1 if canceled. Output the sum. You > can use a simple timer to clear the state for a job after 6 months have > passed. > > Seth > >> On We

Re: CEP library support in Python

2021-09-15 Thread Pedro Silva
Hello, As anyone used streaming sql pattern matching as shown in this email thread to count certain transitions on a stream? Is it feasible? Thank you, Pedro Silva > On 13 Sep 2021, at 11:16, Pedro Silva wrote: > >  > Hello Seth, > > Thank you very much for your reply.

FlinkSQL Sinks

2021-09-15 Thread Pedro Silva
Hello, Is it possible to configure a sink for sql client queries other than the terminal/stdout? Looking at the SQL Client Configuration , it seems that the output of the client is always to

Re: CEP library support in Python

2021-09-13 Thread Pedro Silva
hen a cancel appears on a previously (completed | closed) I decrease my counter but not when a cancel appears after a started or progress state (no counter increment or decrement) ? I hope this example was clear. Thank you for your time! Pedro Silva Em sex., 10 de set. de 2021 às 20:18, Seth Wiesm

CEP library support in Python

2021-09-10 Thread Pedro Silva
upport this library in python or alternatively, another library altogether that can be used in python? Thank you and have a nice weekend, Pedro Silva

Helm chart for Flink

2021-05-17 Thread Pedro Silva
Hello, Forwarding this question from the dev mailing list in case this is a more appropriate list. Does flink have an official Helm Chart? I haven't been able to find any, the closest most up-to-date one seems to be https://github.com/GoogleCloudPlatform/flink-on-k8s-operator. Is this correct or