----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/54647/ -----------------------------------------------------------
(Updated Dec. 13, 2016, 9:36 a.m.) Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina Ramesh, Prateek Maheshwari, Jagadish Venkatraman, and Xinyu Liu. Changes ------- 1st attempt: removing task level programming/wire-up on SystemStreamPartition on both StreamProcessorTask and job-level APIs - Making StreamProcessorTask programming also via MessageStreamsBuilder APIs 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/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)
