You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by "Yi Pan (Data Infrastructure)" <yi...@linkedin.com> on 2016/03/25 00:14:04 UTC
Review Request 45324: SAMZA-914: Initial draft for Java programming
APIs on operators supporting DAGs
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/45324/
-----------------------------------------------------------
Review request for samza.
Repository: samza
Description
-------
SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs
Diffs
-----
build.gradle 16facbbf4dff378c561461786ff186bd9e0000ed
gradle/dependency-versions.gradle 52e25aa53a1edc85d478b48898621b26508ad4bb
samza-operator/src/main/java/org/apache/samza/operators/exception/OperatorException.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/factory/DataStream.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/scan/Scanner.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/SessionWindow.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/Timeout.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/Window.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/task/DataStreamTask.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-sql-calcite/src/test/java/org/apache/samza/sql/calcite/schema/TestAvroSchemaConverter.java PRE-CREATION
samza-sql-core/README.md PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Data.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Schema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Stream.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Table.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorCallback.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorRouter.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SimpleOperator.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroData.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerde.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringData.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringSchema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/NoopOperatorCallback.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorImpl.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleRouter.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/join/StreamStreamJoin.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/join/StreamStreamJoinSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/OrderedStoreKey.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/system/sql/LongOffset.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/system/sql/Offset.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/task/sql/RouterMessageCollector.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/task/sql/SimpleMessageCollector.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeTest.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomWindowOperatorTask.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/UserCallbacksSqlTask.java PRE-CREATION
settings.gradle 4c1aa107a11d413777e69bc4e48847b811aff7d2
Diff: https://reviews.apache.org/r/45324/diff/
Testing
-------
Locally build via ./gradlew clean build
Thanks,
Yi Pan (Data Infrastructure)
Re: Review Request 45324: SAMZA-914: Initial draft for Java
programming APIs on operators supporting DAGs
Posted by "Yi Pan (Data Infrastructure)" <yi...@linkedin.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/45324/
-----------------------------------------------------------
(Updated March 24, 2016, 11:14 p.m.)
Review request for samza.
Bugs: SAMZA-914
https://issues.apache.org/jira/browse/SAMZA-914
Repository: samza
Description
-------
SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs
Diffs
-----
build.gradle 16facbbf4dff378c561461786ff186bd9e0000ed
gradle/dependency-versions.gradle 52e25aa53a1edc85d478b48898621b26508ad4bb
samza-operator/src/main/java/org/apache/samza/operators/exception/OperatorException.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/factory/DataStream.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/scan/Scanner.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/SessionWindow.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/Timeout.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/window/Window.java PRE-CREATION
samza-operator/src/main/java/org/apache/samza/task/DataStreamTask.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-sql-calcite/src/test/java/org/apache/samza/sql/calcite/schema/TestAvroSchemaConverter.java PRE-CREATION
samza-sql-core/README.md PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Data.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Schema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Stream.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Table.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorCallback.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorRouter.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/OperatorSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SimpleOperator.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroData.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerde.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringData.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringSchema.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/NoopOperatorCallback.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorImpl.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleRouter.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/join/StreamStreamJoin.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/join/StreamStreamJoinSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/sql/window/storage/OrderedStoreKey.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/system/sql/LongOffset.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/system/sql/Offset.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/task/sql/RouterMessageCollector.java PRE-CREATION
samza-sql-core/src/main/java/org/apache/samza/task/sql/SimpleMessageCollector.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeTest.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomWindowOperatorTask.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION
samza-sql-core/src/test/java/org/apache/samza/task/sql/UserCallbacksSqlTask.java PRE-CREATION
settings.gradle 4c1aa107a11d413777e69bc4e48847b811aff7d2
Diff: https://reviews.apache.org/r/45324/diff/
Testing
-------
Locally build via ./gradlew clean build
Thanks,
Yi Pan (Data Infrastructure)