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 <jvenkatra...@linkedin.com> Authored: Thu Oct 11 16:20:21 2018 -0700 Committer: Jagadish <jvenkatra...@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(-) ----------------------------------------------------------------------