You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2017/02/27 21:01:41 UTC
[3/3] samza git commit: Merge branch 'samza-fluent-api-v1' of
http://git-wip-us.apache.org/repos/asf/samza into samza-fluent-api-v1
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) <ni...@gmail.com>
Authored: Mon Feb 27 13:00:57 2017 -0800
Committer: Yi Pan (Data Infrastructure) <ni...@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(-)
----------------------------------------------------------------------