-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/54647/
-----------------------------------------------------------
(Updated Jan. 3, 2017, 9:40 p.m.)
Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina
Ramesh, Prateek Maheshwari, Jagadish Venkatraman, and Xinyu Liu.
Changes
-------
Removed task-level API. Added top-level API via MessageStreamGraph
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 (updated)
-----
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
d18536bbbbe8af027e43a312ea3cb74acecf7f59
samza-api/src/main/java/org/apache/samza/operators/MessageStreamGraph.java
PRE-CREATION
samza-api/src/main/java/org/apache/samza/operators/StreamOperatorTask.java
16cf27a3d174a26c915cff4e1b2429df2522f0aa
samza-api/src/main/java/org/apache/samza/operators/StreamSpec.java
PRE-CREATION
samza-api/src/main/java/org/apache/samza/operators/windows/Window.java
56a307de39464f2d91c0a6f4ef424fdef1272a01
samza-api/src/main/java/org/apache/samza/operators/windows/WindowFn.java
8878bf93d34620e56c3ee4b67f722a58203d95d9
samza-api/src/main/java/org/apache/samza/system/ExecutionEnvironment.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/MessageStreamGraphImpl.java
PRE-CREATION
samza-operator/src/main/java/org/apache/samza/operators/MessageStreamImpl.java
231d3f5fd9df36a1119f3b8663657c39aa3e1ecc
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/main/java/org/apache/samza/system/SingleJobExecutionEnvironment.java
PRE-CREATION
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/TestFluentStreamTasks.java
d804bf8d8e527698f68dc253d7e071ce9da2f2ad
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/impl/TestOperatorImpls.java
1d0d547e93c6febe2a57c06fe9ef5293ec9a0d01
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)
