Merge branch 'samza-fluent-api-v1' of http://git-wip-us.apache.org/repos/asf/samza into samza-fluent-api-v1
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/a9b213c1 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/a9b213c1 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/a9b213c1 Branch: refs/heads/samza-fluent-api-v1 Commit: a9b213c1389fe46c7f5575b22dc4e1d20ac7b367 Parents: cf267f8 dde7542 Author: Yi Pan (Data Infrastructure) <nickpa...@gmail.com> Authored: Mon Feb 27 13:00:57 2017 -0800 Committer: Yi Pan (Data Infrastructure) <nickpa...@gmail.com> Committed: Mon Feb 27 13:00:57 2017 -0800 ---------------------------------------------------------------------- .../org/apache/samza/operators/StreamGraph.java | 2 +- .../org/apache/samza/operators/StreamSpec.java | 46 ----------- .../apache/samza/operators/StreamGraphImpl.java | 83 +++++++++----------- .../samza/processorgraph/ExecutionPlanner.java | 34 ++++---- .../samza/example/KeyValueStoreExample.java | 24 +----- .../samza/example/NoContextStreamExample.java | 33 +------- .../samza/example/OrderShipmentJoinExample.java | 35 +-------- .../samza/example/PageViewCounterExample.java | 23 +----- .../samza/example/RepartitionExample.java | 23 +----- .../samza/example/TestBroadcastExample.java | 15 +--- .../apache/samza/example/TestJoinExample.java | 26 ++---- .../apache/samza/example/TestWindowExample.java | 15 +--- .../operators/impl/TestStreamOperatorImpl.java | 1 + 13 files changed, 89 insertions(+), 271 deletions(-) ----------------------------------------------------------------------