-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/47994/
-----------------------------------------------------------
(Updated Oct. 21, 2016, 12:45 a.m.)
Review request for samza, Boris Shkolnik, Chris Pettitt, Chinmay Soman, Jake
Maes, Navina Ramesh, Jagadish Venkatraman, and Xinyu Liu.
Changes
-------
Updated the global operator map (i.e. moving from Operators to within the scope
of each MessageStream object).
@Jake, could you review on this?
Bugs: SAMZA-915
https://issues.apache.org/jira/browse/SAMZA-915
Repository: samza
Description
-------
SAMZA-915: implementation of ChainedOperators and operator runtime impl classes
Diffs (updated)
-----
samza-operator/src/main/java/org/apache/samza/operators/api/MessageStream.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/api/internal/Operators.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/ChainedOperators.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/OperatorFactory.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/join/PartialJoinOpImpl.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/impl/window/SessionWindowImpl.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/api/TestMessageStream.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/api/internal/TestOperators.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestChainedOperators.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestOperatorFactory.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestOperatorImpl.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestOutputMessage.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestSimpleOperatorImpl.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/operators/impl/TestSinkOperatorImpl.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/operators/impl/window/TestSessionWindowImpl.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/BroadcastOperatorTask.java
PRE-CREATION
samza-operator/src/test/java/org/apache/samza/task/InputJsonSystemMessage.java
PRE-CREATION
Diff: https://reviews.apache.org/r/47994/diff/
Testing
-------
./gradlew clean build.
Thanks,
Yi Pan (Data Infrastructure)
