Hi Igal, Thanks for your responses. Regarding "having a pre-processing job that does whatever transformations necessary with the DataStream and outputs to Kafka / Kinesis, and then having a separate StateFun deployment that consumes from that transformed Kafka / Kinesis topic." I was wondering how to do this when using windows. I would like to call the Stateful Function job on each separate window of the stream. This because the stateful function only needs the information from within the window for its processing. Do you have any idea how to achieve this?
Best, Annemarie -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
