samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Milinda Pathirage" <mili...@apache.org>
Subject Review Request 37506: WIP: SAMZA-552 Operator API change: New Builder API
Date Sun, 16 Aug 2015 15:06:52 GMT

-----------------------------------------------------------
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


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message