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/11/27 09:48:52 UTC
[45/50] 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/65f58bfa
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/65f58bfa
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/65f58bfa
Branch: refs/heads/master
Commit: 65f58bfa010ae60af0584e9a464028e338d1995f
Parents: e0e5e87 5f7a22c
Author: Jagadish <jv...@linkedin.com>
Authored: Mon Nov 26 14:17:14 2018 -0800
Committer: Jagadish <jv...@linkedin.com>
Committed: Mon Nov 26 14:17:14 2018 -0800
----------------------------------------------------------------------
build.gradle | 1 +
docs/_committers/hai-lu.md | 28 +++
.../versioned/jobs/configuration-table.html | 17 ++
.../apache/samza/config/JavaTableConfig.java | 118 +++++++++++++
.../apache/samza/metrics/SamzaHistogram.java | 79 +++++++++
.../org/apache/samza/table/TableProvider.java | 15 --
.../samza/table/TableProviderFactory.java | 10 +-
.../java/org/apache/samza/table/TableSpec.java | 172 -------------------
.../table/descriptors/BaseTableDescriptor.java | 68 +++-----
.../descriptors/CachingTableDescriptor.java | 70 ++++----
.../descriptors/GuavaCacheTableDescriptor.java | 32 ++--
.../descriptors/HybridTableDescriptor.java | 3 +-
.../table/descriptors/LocalTableDescriptor.java | 105 ++++++++---
.../descriptors/RemoteTableDescriptor.java | 122 ++++++-------
.../table/descriptors/TableDescriptor.java | 17 ++
.../samza/table/TestBaseTableDescriptor.java | 73 ++++++++
.../consumer/EventHubSystemConsumer.java | 2 +-
.../system/eventhub/metrics/SamzaHistogram.java | 83 ---------
.../eventhub/producer/AsyncSystemProducer.java | 2 +-
.../StreamApplicationDescriptorImpl.java | 10 +-
.../TaskApplicationDescriptorImpl.java | 8 +-
.../apache/samza/config/JavaTableConfig.java | 88 ----------
.../samza/execution/ExecutionPlanner.java | 35 ++--
.../org/apache/samza/execution/JobGraph.java | 14 +-
.../samza/execution/JobGraphJsonGenerator.java | 41 ++---
.../org/apache/samza/execution/JobNode.java | 10 +-
.../JobNodeConfigurationGenerator.java | 38 ++--
.../execution/OperatorSpecGraphAnalyzer.java | 29 ++--
.../samza/operators/MessageStreamImpl.java | 6 +-
.../org/apache/samza/operators/TableImpl.java | 18 +-
.../samza/operators/impl/OperatorImpl.java | 16 +-
.../operators/impl/SendToTableOperatorImpl.java | 2 +-
.../impl/StreamTableJoinOperatorImpl.java | 13 +-
.../samza/operators/spec/OperatorSpecs.java | 14 +-
.../operators/spec/SendToTableOperatorSpec.java | 14 +-
.../spec/StreamTableJoinOperatorSpec.java | 14 +-
.../apache/samza/table/BaseTableProvider.java | 40 ++---
.../samza/table/TableConfigGenerator.java | 66 +------
.../org/apache/samza/table/TableManager.java | 54 ++----
.../samza/table/caching/CachingTable.java | 3 -
.../table/caching/CachingTableProvider.java | 24 +--
.../caching/CachingTableProviderFactory.java | 7 +-
.../table/caching/guava/GuavaCacheTable.java | 3 -
.../caching/guava/GuavaCacheTableProvider.java | 13 +-
.../guava/GuavaCacheTableProviderFactory.java | 6 +-
.../table/remote/RemoteReadWriteTable.java | 33 ----
.../samza/table/remote/RemoteReadableTable.java | 24 ++-
.../samza/table/remote/RemoteTableProvider.java | 57 +++---
.../remote/RemoteTableProviderFactory.java | 10 +-
.../table/utils/DefaultTableReadMetrics.java | 2 +
.../apache/samza/task/EpochTimeScheduler.java | 6 +-
.../org/apache/samza/config/MetricsConfig.scala | 11 ++
.../apache/samza/container/SamzaContainer.scala | 2 +-
.../TestStreamApplicationDescriptorImpl.java | 9 +-
.../TestTaskApplicationDescriptorImpl.java | 3 -
.../org/apache/samza/context/MockContext.java | 6 +-
.../samza/execution/TestExecutionPlanner.java | 44 ++---
.../execution/TestJobGraphJsonGenerator.java | 15 ++
.../TestJobNodeConfigurationGenerator.java | 94 ++--------
.../samza/operators/TestJoinOperator.java | 1 +
.../samza/operators/TestMessageStreamImpl.java | 11 +-
.../samza/operators/impl/TestOperatorImpl.java | 5 +-
.../operators/impl/TestOperatorImplGraph.java | 1 +
.../impl/TestStreamTableJoinOperatorImpl.java | 5 +-
.../operators/impl/TestWindowOperator.java | 1 +
.../operators/spec/OperatorSpecTestUtils.java | 11 +-
.../samza/operators/spec/TestOperatorSpec.java | 26 +--
.../apache/samza/table/TestTableManager.java | 52 +-----
.../samza/table/caching/TestCachingTable.java | 53 +++---
.../descriptors/TestLocalTableDescriptor.java | 162 +++++++++++++++++
.../descriptors/TestRemoteTableDescriptor.java | 88 ++++++----
.../descriptors/InMemoryTableDescriptor.java | 38 ++--
.../descriptors/InMemoryTableProvider.java | 71 --------
.../InMemoryTableProviderFactory.java | 33 ----
.../inmemory/TestInMemoryTableDescriptor.java | 65 +++++++
.../TestInMemoryTableDescriptor.java | 55 ------
.../descriptors/TestInMemoryTableProvider.java | 67 --------
.../kv/descriptors/RocksDbTableDescriptor.java | 64 +++----
.../kv/descriptors/RocksDbTableProvider.java | 75 --------
.../RocksDbTableProviderFactory.java | 31 ----
.../descriptors/TestRocksDbTableDescriptor.java | 97 ++++++-----
.../descriptors/TestRocksDbTableProvider.java | 68 --------
.../samza/storage/kv/LocalReadWriteTable.java | 3 -
.../samza/storage/kv/LocalReadableTable.java | 8 +-
.../samza/storage/kv/LocalTableProvider.java | 103 +----------
.../storage/kv/LocalTableProviderFactory.java | 31 ++++
.../kv/descriptors/TestLocalTableProvider.java | 103 +----------
.../apache/samza/sql/avro/AvroRelConverter.java | 33 +++-
.../samza/sql/translator/JoinTranslator.java | 12 +-
.../translator/LogicalAggregateTranslator.java | 8 +-
.../samza/sql/translator/ProjectTranslator.java | 65 +++++--
.../samza/sql/translator/QueryTranslator.java | 21 +--
.../SamzaSqlRemoteTableJoinFunction.java | 9 +-
.../translator/SamzaSqlTableJoinFunction.java | 5 +
.../samza/sql/avro/TestAvroRelConversion.java | 52 +++++-
.../samza/sql/e2e/TestSamzaSqlRemoteTable.java | 95 +++++++++-
.../samza/sql/system/TestAvroSystemFactory.java | 13 +-
.../samza/sql/testutil/SamzaSqlTestConfig.java | 11 +-
.../sql/testutil/TestMetricsRegistryImpl.java | 117 +++++++++++++
.../sql/translator/TestJoinTranslator.java | 2 +-
.../sql/translator/TestProjectTranslator.java | 92 ++++++----
.../sql/translator/TestQueryTranslator.java | 24 +--
.../sql/translator/TranslatorTestBase.java | 11 +-
.../samza/example/TaskApplicationExample.java | 5 +-
.../test/functions/TestSchedulerFunction.java | 93 ++++++++++
.../test/samzasql/TestSamzaSqlEndToEnd.java | 29 +++-
106 files changed, 1967 insertions(+), 1977 deletions(-)
----------------------------------------------------------------------