-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/47835/
-----------------------------------------------------------
(Updated June 7, 2016, 5:20 p.m.)
Review request for samza, Boris Shkolnik, Chris Pettitt, Chinmay Soman, Jake
Maes, Navina Ramesh, Jagadish Venkatraman, and Xinyu Liu.
Bugs: SAMZA-914
https://issues.apache.org/jira/browse/SAMZA-914
Repository: samza
Description
-------
SAMZA-914: initial draft implementation of operator programming API.
Diffs (updated)
-----
build.gradle 16facbbf4dff378c561461786ff186bd9e0000ed
gradle/dependency-versions.gradle 52e25aa53a1edc85d478b48898621b26508ad4bb
samza-operator/README.md PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/Filter.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/FlatMapper.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/Mapper.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/Scanner.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/Sink.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/StreamOperator.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/Transformer.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/Data.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/DataStream.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/InputSystemStream.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/Offset.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/Schema.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/data/Tuple.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/join/Joiner.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/window/Limit.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/window/SessionWindow.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/window/Timeout.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/window/TriggerBuilder.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/window/Window.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/Pipeline.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/ProcessorContext.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/SimpleOperatorImpl.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/IncomingMessageTuple.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/LongOffset.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/avro/AvroData.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/avro/AvroSchema.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/serializers/SqlAvroSerde.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/serializers/SqlAvroSerdeFactory.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/serializers/SqlStringSerde.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/serializers/SqlStringSerdeFactory.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/string/StringData.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/data/string/StringSchema.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/task/DataStreamTask.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/api/TestScanner.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/api/data/TestDataStream.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/api/window/TestSessionWindow.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/data/serializers/SqlAvroSerdeTest.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/DataStreamJoinTask.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/DataStreamSplitTask.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/DataStreamUserTask.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/TestDataStreamTask.java
PRE-CREATION
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/planner/QueryPlanner.java
PRE-CREATION
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/planner/SamzaCalciteConnection.java
PRE-CREATION
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/planner/SamzaQueryPreparingStatement.java
PRE-CREATION
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/planner/SamzaSqlValidator.java
PRE-CREATION
samza-sql-calcite/src/main/java/org/apache/samza/sql/calcite/schema/AvroSchemaConverter.java
PRE-CREATION
samza-sql-calcite/src/test/java/org/apache/samza/sql/calcite/planner/SamzaStreamTableFactory.java
PRE-CREATION
samza-sql-calcite/src/test/java/org/apache/samza/sql/calcite/planner/TestQueryPlanner.java
PRE-CREATION
samza-sql-calcite/src/test/java/org/apache/samza/sql/calcite/schema/TestAvroSchemaConverter.java
PRE-CREATION
settings.gradle 4c1aa107a11d413777e69bc4e48847b811aff7d2
Diff: https://reviews.apache.org/r/47835/diff/
Testing
-------
./gradlew clean build
Thanks,
Yi Pan (Data Infrastructure)
