-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37506/
-----------------------------------------------------------
Review request for samza, Yi Pan (Data Infrastructure) and Navina Ramesh.
Bugs: SAMZA-552
https://issues.apache.org/jira/browse/SAMZA-552
Repository: samza
Description
-------
New proposal for TopologuBuilder API proposed in rb34500
(https://reviews.apache.org/r/34500/).
* Created a new class called TopologyBuilderV2 instead of changing existing
TopologyBuilder
* org.apache.samza.sql.operators.factory.TestTopologyBuilderV2 contains two
tests which demonstrate the basic usage of the new API
* Window and aggregate related draft APIs are not done yet
* This is a WIP, please feel free to comment on the APIs
Diffs
-----
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/schema/AvroSchemaConverter.java
705c0ffadd0982defae686bb0df178e9a7cbef8c
samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomWindowOperatorTask.java
20dc70179e74070e8feb617b6a7b3b62ef5c1156
samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java
9124e3c7191aac8a738345c02b260baae811c5c5
samza-sql-core/src/test/java/org/apache/samza/task/sql/UserCallbacksSqlTask.java
96e96c363e723c20c30622d1253588f66166b206
Diff: https://reviews.apache.org/r/37506/diff/
Testing
-------
./gradlew :samza-sql-core:test passed
Thanks,
Milinda Pathirage
