You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/10/12 02:48:06 UTC
[22/32] samza git commit: Merge branch 'master' of
https://github.com/apache/samza
Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/85050645
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/85050645
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/85050645
Branch: refs/heads/master
Commit: 85050645cf0673d3f4e89a5461b1f565d2ccf846
Parents: cad265f 992b217
Author: Jagadish <jv...@linkedin.com>
Authored: Thu Oct 11 16:20:21 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Thu Oct 11 16:20:21 2018 -0700
----------------------------------------------------------------------
.../samza/operators/BaseTableDescriptor.java | 10 +-
.../table/remote/RemoteTableDescriptor.java | 4 +-
.../kv/inmemory/InMemoryTableDescriptor.java | 4 +-
.../storage/kv/RocksDbTableDescriptor.java | 98 +++++++++++++++++++-
.../kv/BaseLocalStoreBackedTableDescriptor.java | 20 +++-
.../apache/samza/test/framework/TestRunner.java | 45 +++++++--
.../system/InMemorySystemDescriptor.java | 1 -
.../AsyncStreamTaskIntegrationTest.java | 3 +-
.../StreamApplicationIntegrationTest.java | 61 +++++++++++-
.../framework/StreamTaskIntegrationTest.java | 93 +++++++++++++++++++
.../table/PageViewToProfileJoinFunction.java | 2 +-
.../table/TestLocalTableWithSideInputs.java | 20 ++--
12 files changed, 322 insertions(+), 39 deletions(-)
----------------------------------------------------------------------