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/7887d884 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/7887d884 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/7887d884 Branch: refs/heads/NewKafkaSystemConsumer Commit: 7887d884e8a062563a7e4b8b418d817828f51f23 Parents: 88f8559 a8ddede Author: Boris S <[email protected]> Authored: Sun Aug 12 23:48:39 2018 -0700 Committer: Boris S <[email protected]> Committed: Sun Aug 12 23:48:39 2018 -0700 ---------------------------------------------------------------------- .../java/org/apache/samza/config/Config.java | 3 + .../org/apache/samza/metrics/ListGauge.java | 3 +- .../org/apache/samza/runtime/LocationId.java | 60 +++ .../samza/runtime/LocationIdProvider.java | 28 ++ .../runtime/LocationIdProviderFactory.java | 28 ++ .../org/apache/samza/table/ReadWriteTable.java | 43 +- .../org/apache/samza/table/ReadableTable.java | 19 + .../org/apache/samza/config/TestConfig.java | 41 ++ .../DefaultLocationIdProviderFactory.java | 32 ++ .../samza/runtime/RemoteApplicationRunner.java | 69 +--- .../storage/TaskSideInputStorageManager.java | 38 +- .../samza/system/inmemory/InMemoryManager.java | 10 +- .../system/inmemory/InMemorySystemAdmin.java | 6 +- .../system/inmemory/InMemorySystemFactory.java | 2 +- .../samza/table/caching/CachingTable.java | 237 ++++++++--- .../table/caching/CachingTableDescriptor.java | 14 - .../table/caching/CachingTableProvider.java | 4 +- .../table/caching/guava/GuavaCacheTable.java | 140 ++++++- .../samza/table/remote/CreditFunction.java | 36 -- .../table/remote/RemoteReadWriteTable.java | 157 ++++--- .../samza/table/remote/RemoteReadableTable.java | 243 ++++++++--- .../table/remote/RemoteTableDescriptor.java | 47 ++- .../samza/table/remote/RemoteTableProvider.java | 73 +++- .../samza/table/remote/TableRateLimiter.java | 167 ++++++++ .../samza/table/remote/TableReadFunction.java | 54 ++- .../samza/table/remote/TableWriteFunction.java | 86 +++- .../table/utils/DefaultTableReadMetrics.java | 2 + .../table/utils/DefaultTableWriteMetrics.java | 4 + .../org/apache/samza/config/JobConfig.scala | 5 + .../MetricsSnapshotReporterFactory.scala | 4 +- .../runtime/TestRemoteApplicationRunner.java | 70 ++++ .../TestTaskSideInputStorageManager.java | 295 +++++++++++++ .../samza/table/caching/TestCachingTable.java | 275 +++++++----- .../samza/table/remote/TestRemoteTable.java | 413 +++++++++++++++++++ .../table/remote/TestRemoteTableDescriptor.java | 55 +-- .../table/remote/TestTableRateLimiter.java | 103 +++++ .../samza/storage/kv/RocksDbTableProvider.java | 4 + .../kv/LocalStoreBackedReadWriteTable.java | 49 +++ .../kv/LocalStoreBackedReadableTable.java | 23 ++ .../sql/impl/ConfigBasedIOResolverFactory.java | 4 +- .../sql/interfaces/SqlIOResolverFactory.java | 5 +- .../sql/runner/SamzaSqlApplicationConfig.java | 2 +- .../sql/testutil/TestIOResolverFactory.java | 34 +- .../apache/samza/test/table/TestLocalTable.java | 61 +++ .../table/TestLocalTableWithSideInputs.java | 161 ++++++++ .../samza/test/table/TestRemoteTable.java | 40 +- .../apache/samza/test/table/TestTableData.java | 22 +- .../table/TestTableDescriptorsProvider.java | 3 +- 48 files changed, 2722 insertions(+), 552 deletions(-) ----------------------------------------------------------------------
