In the process of design/refining the physical operator layer for SAMZA-552, there is a need to design/implement a set of fluent programming APIs s.t. users may be able to directly write Java programs using the physical operators.
The programming APIs would serve as an intermediate layer that serves the following purposes:
- Users can choose to directly use physical operators (like window/join/filter etc.) in their Java code
- The SQL parser and engine can use this API to construct the physical operators and the execution DAG.
|Implement operator programming APIs to support linear pipeline
|Implement operator programing APIs to support join
|Refactor classes from samza-operator/api into samza-api.
|Refactor public Operator APIs
|Provide Operator implementations access to KeyValueStorageEngines