Andrey Novitskiy

We should be able to enrich streams from outside sources/systems without copying data but by simply looking-up each key - similar to Look-up Joins in Flink

Our join should be point-in-time correct - similar to Flink's Temporal Join

Similar to #75, we want to have a generic state abstraction on JoinOperator which can later be shared with window operator and other operators.

Master task to keep track of JoinOperator maturity

Currently we have state all over the operator class. We need to centralize it and come up with a good abstraction which we can later re-use (similar to join state)

Currently we have tight dependency on Ray in our codebase. We should create an abstract Actor model that will decouple our engine from Ray and will support pluggable execution environments...

Current operator assumes that each event processing is a non-blocking operation - we simply have a thread with while loop which processes elements from upstreams one by ine . It...

For certain features we want to be able to init some persistent-less state (e.g client for a third-party service) to be accessible when executing udfs (e.g. a simple dict). We...

Hi, I was going through Chronon docs trying to understand details on how the online/offline consistency is guaranteed but could not find exact details. I'm particularly interested in 3 scenarios:...