-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/54647/
-----------------------------------------------------------
(Updated Dec. 23, 2016, 10:57 p.m.)
Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina
Ramesh, Prateek Maheshwari, Jagadish Venkatraman, and Xinyu Liu.
Changes
-------
Link to SAMZA-1073
Bugs: SAMZA-1073
https://issues.apache.org/jira/browse/SAMZA-1073
Repository: samza
Description
-------
WIP: job level fluent API. Adding MessageStreamsBuilder to create SystemStream
level DAG
Code example of this API to work w/ standalone and pipeline jobs are here:
https://github.com/nickpan47/samza/blob/standalone-operators/samza-operator/src/test/java/org/apache/samza/pipeline/TestBasePipelineWithStreamsBuilder.java
and
https://github.com/nickpan47/samza/blob/standalone-operators/samza-operator/src/test/java/org/apache/samza/processor/TestMessageStreamsBuilderBasedProcessor.java
Diffs
-----
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
d18536bbbbe8af027e43a312ea3cb74acecf7f59
samza-api/src/main/java/org/apache/samza/operators/MessageStreamsBuilder.java
PRE-CREATION
samza-api/src/main/java/org/apache/samza/operators/StreamOperatorTask.java
16cf27a3d174a26c915cff4e1b2429df2522f0aa
samza-operator/src/main/java/org/apache/samza/operators/MessageStreamImpl.java
231d3f5fd9df36a1119f3b8663657c39aa3e1ecc
samza-operator/src/main/java/org/apache/samza/operators/MessageStreamsBuilderImpl.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/MessageStreamsBuilderTask.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/StreamOperatorAdaptorTask.java
152cd92810b9eed27acb53007d1ab35d50fa86b9
samza-operator/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java
c77914eebc96b0a9fbf296f10557c975cd7ed8df
samza-operator/src/main/java/org/apache/samza/operators/impl/OperatorImpls.java
79446be310dfb70415003e217eaaa5c079bdac50
samza-operator/src/main/java/org/apache/samza/operators/impl/SessionWindowOperatorImpl.java
e8a635c60fcbcadefc5ad9e605e9103ea4a5d0dc
samza-operator/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java
8b75cdc6abe66724988870a2992e2aec211f0087
samza-operator/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java
f622b343ea7183ffc734866ff026137a04d03023
samza-operator/src/main/java/org/apache/samza/operators/spec/PartialJoinOperatorSpec.java
f74f35d584d6e14b17bce139195b9566f8365378
samza-operator/src/main/java/org/apache/samza/operators/spec/SinkOperatorSpec.java
4348bc0e75ce45c9a6d5b555dfb6407b180137dc
samza-operator/src/main/java/org/apache/samza/operators/spec/StreamOperatorSpec.java
ed18da4f7d311aa540a145a275932aa4426d52da
samza-operator/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java
2f5b1e76f2dfbecec44195142ffe309f46226d6c
samza-operator/src/test/java/org/apache/samza/operators/BroadcastTask.java
e45d068eae36647dcee2e1df07e770871656f78f
samza-operator/src/test/java/org/apache/samza/operators/JoinTask.java
1b106096669c75d43007a655e650442929853ef4
samza-operator/src/test/java/org/apache/samza/operators/TestFluentStreamAdaptorTask.java
61bb32ae79ade7c4db1402a494dcf43a86e7cdf1
samza-operator/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java
2ad6461716c55b0e30ff31734402600c4aae941c
samza-operator/src/test/java/org/apache/samza/operators/WindowTask.java
f33510e52b75dcb9a536dabd93d18efd65218c71
samza-operator/src/test/java/org/apache/samza/operators/spec/TestOperatorSpecs.java
028bd6715e3ca409bd7b452e9871508fcc81128f
Diff: https://reviews.apache.org/r/54647/diff/
Testing
-------
Thanks,
Yi Pan (Data Infrastructure)
