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/78ad578c Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/78ad578c Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/78ad578c Branch: refs/heads/NewKafkaSystemConsumer Commit: 78ad578cc022af3f9c5f9a15826a9dc010502a89 Parents: 88f8559 d28f0c8 Author: Boris S <bor...@apache.org> Authored: Tue Aug 7 19:04:17 2018 -0700 Committer: Boris S <bor...@apache.org> Committed: Tue Aug 7 19:04:17 2018 -0700 ---------------------------------------------------------------------- .../org/apache/samza/metrics/ListGauge.java | 3 +- .../samza/runtime/RemoteApplicationRunner.java | 69 +---- .../storage/TaskSideInputStorageManager.java | 38 ++- .../MetricsSnapshotReporterFactory.scala | 4 +- .../runtime/TestRemoteApplicationRunner.java | 70 +++++ .../TestTaskSideInputStorageManager.java | 295 +++++++++++++++++++ .../samza/storage/kv/RocksDbTableProvider.java | 4 + .../table/TestLocalTableWithSideInputs.java | 161 ++++++++++ .../apache/samza/test/table/TestTableData.java | 22 +- .../table/TestTableDescriptorsProvider.java | 2 +- 10 files changed, 597 insertions(+), 71 deletions(-) ----------------------------------------------------------------------
