This is an automated email from the ASF dual-hosted git repository.
boryas pushed a change to branch 1.2.0
in repository https://gitbox.apache.org/repos/asf/samza.git.
from f80659d replaced verstion to be 1.2.0
add a31a7aa reduce debugging from info to debug in
KafkaCheckpointManager.java
add 410ce78 Merge branch 'master' of https://github.com/apache/samza
add 5e6f5fb Merge branch 'master' of https://github.com/apache/samza
add d4620d6 Merge branch 'master' of https://github.com/apache/samza
add bbffb79 Merge branch 'master' of https://github.com/apache/samza
add 010fa16 Merge branch 'master' of https://github.com/apache/samza
add 06b1ac3 Merge branch 'master' of https://github.com/sborya/samza
add 1ad58d4 Merge branch 'master' of https://github.com/apache/samza
add dd39d08 Merge branch 'master' of https://github.com/apache/samza
add 67e611e Merge branch 'master' of https://github.com/apache/samza
add 0edf343 Merge branch 'master' of https://github.com/apache/samza
add 88f8559 Merge branch 'master' of https://github.com/apache/samza
add 7887d88 Merge branch 'master' of https://github.com/apache/samza
add 78ad578 Merge branch 'master' of https://github.com/apache/samza
add afb34d9 Merge branch 'master' of https://github.com/sborya/samza
add 57fca52 Merge branch 'master' of https://github.com/apache/samza
add 7f7b559 Merge branch 'master' of https://github.com/apache/samza
add 8ab04b2 Merge branch 'master' of https://github.com/apache/samza
add add733b Merge branch 'master' of https://github.com/apache/samza
add 728dc18 Merge branch 'master' of https://github.com/apache/samza
add 952dbbe Merge branch 'master' of https://github.com/apache/samza
add 927adff Merge branch 'master' of https://github.com/apache/samza
add ceebdc3 Merge branch 'master' of https://github.com/apache/samza
add 4f0a746 Merge branch 'master' of https://github.com/apache/samza
add cdd811d Merge branch 'master' of https://github.com/apache/samza
add f6966a8 Merge branch 'master' of https://github.com/apache/samza
add 450ea2e Merge branch 'master' of https://github.com/apache/samza
add 5f5d7a3 Merge branch 'master' of https://github.com/apache/samza
add 058217e Merge branch 'master' of https://github.com/apache/samza
add 7821072 Merge branch 'master' of https://github.com/apache/samza
add 74dd138 Merge branch 'master' of https://github.com/apache/samza
add 92180fd Merge branch 'master' of https://github.com/apache/samza
add 712e68a Merge branch 'master' of https://github.com/apache/samza
add d56feee Merge branch 'master' of https://github.com/apache/samza
add 8964955 Merge branch 'master' of https://github.com/apache/samza
add 15f62c4 Merge branch 'master' of https://github.com/apache/samza
add 7d60510 Merge branch 'master' of https://github.com/apache/samza
add 70c6f2b Merge branch 'master' of https://github.com/apache/samza
add 8aa77a1 Merge branch 'master' of https://github.com/apache/samza
add 6f6cf92 Merge branch 'master' of https://github.com/apache/samza
add 1016240 Merge branch 'master' of https://github.com/sborya/samza
add c7d94c8 Merge branch 'master' of https://github.com/apache/samza
add 29704e4 Merge branch 'master' of https://github.com/apache/samza
add d940126 Merge branch 'master' of https://github.com/apache/samza
add 838b099 Merge branch 'master' of https://github.com/apache/samza
add 08b2c68 Merge branch 'master' of https://github.com/sborya/samza
add 5827f61 Merge branch 'master' of https://github.com/apache/samza
add 21729af Merge branch 'master' of https://github.com/sborya/samza
add 45b50d7 Merge branch 'master' of https://github.com/apache/samza
add 8ff1c99 Merge branch 'master' of https://github.com/apache/samza
add 65ce8d3 Merge branch 'master' of https://github.com/apache/samza
add 3f8e978 Merge branch 'master' of https://github.com/apache/samza
add ab69474 Merge branch 'master' of https://github.com/apache/samza
add 11d255f Merge branch 'master' of https://github.com/apache/samza
add c29978b Merge branch 'master' of https://github.com/apache/samza
add 2f04b98 Merge branch 'master' of https://github.com/apache/samza
add 627debe Merge branch 'master' of https://github.com/apache/samza
add 3a3b300 Merge branch 'master' of https://github.com/apache/samza
add f753d60 SAMZA-2185: Add ability to expose remote store specific
features in remote table (#1034)
add 063a819 SAMZA-2046: Startpoint fan out implementation (#1027)
add bf97458 Merge branch 'master' of https://github.com/apache/samza
add 4e79a60 added gpg key for [email protected]
add 17a295c Merge pull request #1037 from sborya/KEYS
add f25ff1e Merge branch 'master' into 1.2.0
add 59b73d4 SAMZA-2172: Make High Level applications respect
job.container.thread.pool.size
add b786d8b SAMZA-1531: Support run.id in standalone for batch processing.
add e1194b1 Revert "SAMZA-2155: Remove log4j log4j2 dependency from
samza-test"
add 21832ae SAMZA-2225: Update configurations in standalone integration
tests. (#1054)
new 6cef509 added LICENCE and NOTICE
new 085266a kafka 11
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
KEYS | 37 +++
build.gradle | 5 +-
.../learn/documentation/versioned/api/table-api.md | 77 ++++-
.../org/apache/samza/startpoint/Startpoint.java | 5 +
.../apache/samza/table/AsyncReadWriteTable.java | 44 ++-
.../org/apache/samza/table/ReadWriteTable.java | 44 ++-
.../samza/table/remote/BaseTableFunction.java | 59 ++++
.../apache/samza/table/remote/TableFunction.java | 67 ++++
.../samza/table/remote/TableRateLimiter.java | 58 +++-
.../samza/table/remote/TableReadFunction.java | 40 ++-
.../samza/table/remote/TableWriteFunction.java | 63 +++-
.../samza/table/remote/TestTableRateLimiter.java | 22 +-
.../samza/coordinator/AzureCoordinationUtils.java | 19 +-
.../org/apache/samza/coordinator/AzureLock.java | 11 +-
.../samza/coordinator/ClusterMembership.java | 60 ++++
.../samza/coordinator/CoordinationConstants.java | 12 +-
.../samza/coordinator/CoordinationUtils.java | 9 +-
.../apache/samza/coordinator/DistributedLock.java | 11 +-
.../coordinator/DistributedLockWithState.java | 42 ---
.../apache/samza/coordinator/RunIdGenerator.java | 110 ++++++
.../apache/samza/execution/LocalJobPlanner.java | 126 +++++--
.../samza/runtime/LocalApplicationRunner.java | 93 +++++-
.../samza/startpoint/StartpointFanOutPerTask.java | 89 +++++
.../org/apache/samza/startpoint/StartpointKey.java | 73 ----
.../samza/startpoint/StartpointKeySerializer.java | 80 -----
.../apache/samza/startpoint/StartpointManager.java | 305 +++++++++++------
.../samza/startpoint/StartpointObjectMapper.java | 72 ++++
.../apache/samza/startpoint/StartpointSerde.java | 59 ----
.../apache/samza/table/caching/CachingTable.java | 94 ++++--
.../samza/table/caching/guava/GuavaCacheTable.java | 24 +-
.../table/ratelimit/AsyncRateLimitedTable.java | 95 ++++--
.../samza/table/remote/AsyncRemoteTable.java | 55 ++-
.../org/apache/samza/table/remote/RemoteTable.java | 104 ++++--
.../samza/table/remote/RemoteTableProvider.java | 23 +-
.../samza/table/retry/AsyncRetriableTable.java | 34 +-
.../samza/table/retry/RetriableReadFunction.java | 102 ------
.../samza/table/retry/RetriableWriteFunction.java | 120 -------
.../org/apache/samza/table/retry/RetryMetrics.java | 3 +-
.../org/apache/samza/table/utils/TableMetrics.java | 8 +
.../org/apache/samza/task/StreamOperatorTask.java | 99 ++++--
.../samza/task/StreamOperatorTaskFactory.java | 11 +-
.../org/apache/samza/task/TaskFactoryUtil.java | 28 +-
.../org/apache/samza/zk/ZkClusterMembership.java | 71 ++++
.../org/apache/samza/zk/ZkCoordinationUtils.java | 10 +-
.../samza/zk/ZkCoordinationUtilsFactory.java | 4 +-
.../org/apache/samza/zk/ZkDistributedLock.java | 94 +++---
.../apache/samza/zk/ZkMetadataStoreFactory.java | 6 +-
.../apache/samza/checkpoint/OffsetManager.scala | 42 ++-
.../apache/samza/container/SamzaContainer.scala | 1 -
.../samza/coordinator/TestRunIdGenerator.java | 93 ++++++
.../samza/execution/TestLocalJobPlanner.java | 34 +-
.../samza/runtime/TestLocalApplicationRunner.java | 122 ++++++-
.../startpoint/StartpointManagerTestUtil.java | 25 +-
.../apache/samza/startpoint/StartpointMock.java | 25 +-
.../apache/samza/startpoint/TestStartpointKey.java | 83 -----
.../samza/startpoint/TestStartpointManager.java | 199 ++++++-----
...tSerde.java => TestStartpointObjectMapper.java} | 39 ++-
.../samza/table/caching/TestCachingTable.java | 12 +-
.../table/ratelimit/TestAsyncRateLimitedTable.java | 282 +++++++++++++---
.../samza/table/remote/TestAsyncRemoteTable.java | 69 +++-
.../apache/samza/table/remote/TestRemoteTable.java | 302 ++++++++++++++---
.../descriptors/TestRemoteTableDescriptor.java | 8 +-
.../samza/table/retry/TestAsyncRetriableTable.java | 174 ++++++++--
.../table/retry/TestRetriableTableFunctions.java | 312 ------------------
.../apache/samza/task/TestStreamOperatorTask.java | 34 +-
.../org/apache/samza/task/TestTaskFactoryUtil.java | 21 +-
.../apache/samza/zk/TestZkClusterMembership.java | 133 ++++++++
.../org/apache/samza/zk/TestZkDistributedLock.java | 126 +++++++
.../org/apache/samza/zk/TestZkMetadataStore.java | 2 +-
.../samza/checkpoint/TestOffsetManager.scala | 125 ++++---
.../couchbase/BaseCouchbaseTableFunction.java | 16 +-
.../couchbase/CouchbaseTableReadFunction.java | 16 +-
.../couchbase/CouchbaseTableWriteFunction.java | 15 +-
.../couchbase/TestCouchbaseTableReadFunction.java | 9 +-
.../couchbase/TestCouchbaseTableWriteFunction.java | 13 +-
.../org/apache/samza/storage/kv/LocalTable.java | 38 +--
.../sql/util/RemoteStoreIOResolverTestFactory.java | 7 +-
samza-test/src/main/python/configs/downloads.json | 2 +-
samza-test/src/main/python/configs/kafka.json | 22 +-
.../src/main/python/standalone_deployment.py | 4 +-
samza-test/src/main/python/tests/zk_client.py | 3 +-
.../src/main}/resources/log4j.xml | 53 +--
.../src/main}/resources/log4j2.xml | 28 +-
.../processor/TestZkLocalApplicationRunner.java | 321 ++++++++++++++++--
.../table/TestCouchbaseRemoteTableEndToEnd.java | 29 +-
.../samza/test/table/TestRemoteTableEndToEnd.java | 367 ++++++++++++++++++---
LICENSE => samza-tools/LICENSE | 0
NOTICE => samza-tools/NOTICE | 0
88 files changed, 4020 insertions(+), 1863 deletions(-)
create mode 100644
samza-api/src/main/java/org/apache/samza/table/remote/BaseTableFunction.java
create mode 100644
samza-api/src/main/java/org/apache/samza/table/remote/TableFunction.java
create mode 100644
samza-core/src/main/java/org/apache/samza/coordinator/ClusterMembership.java
copy
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtilsFactory.java
=>
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java
(72%)
rename {samza-azure =>
samza-core}/src/main/java/org/apache/samza/coordinator/DistributedLock.java
(78%)
delete mode 100644
samza-core/src/main/java/org/apache/samza/coordinator/DistributedLockWithState.java
create mode 100644
samza-core/src/main/java/org/apache/samza/coordinator/RunIdGenerator.java
create mode 100644
samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java
delete mode 100644
samza-core/src/main/java/org/apache/samza/startpoint/StartpointKey.java
delete mode 100644
samza-core/src/main/java/org/apache/samza/startpoint/StartpointKeySerializer.java
create mode 100644
samza-core/src/main/java/org/apache/samza/startpoint/StartpointObjectMapper.java
delete mode 100644
samza-core/src/main/java/org/apache/samza/startpoint/StartpointSerde.java
delete mode 100644
samza-core/src/main/java/org/apache/samza/table/retry/RetriableReadFunction.java
delete mode 100644
samza-core/src/main/java/org/apache/samza/table/retry/RetriableWriteFunction.java
copy samza-api/src/main/java/org/apache/samza/task/StreamTaskFactory.java =>
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
(74%)
create mode 100644
samza-core/src/main/java/org/apache/samza/zk/ZkClusterMembership.java
create mode 100644
samza-core/src/test/java/org/apache/samza/coordinator/TestRunIdGenerator.java
copy samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java
=> samza-core/src/test/java/org/apache/samza/startpoint/StartpointMock.java
(66%)
delete mode 100644
samza-core/src/test/java/org/apache/samza/startpoint/TestStartpointKey.java
rename
samza-core/src/test/java/org/apache/samza/startpoint/{TestStartpointSerde.java
=> TestStartpointObjectMapper.java} (55%)
delete mode 100644
samza-core/src/test/java/org/apache/samza/table/retry/TestRetriableTableFunctions.java
create mode 100644
samza-core/src/test/java/org/apache/samza/zk/TestZkClusterMembership.java
create mode 100644
samza-core/src/test/java/org/apache/samza/zk/TestZkDistributedLock.java
copy {samza-log4j/src/test => samza-test/src/main}/resources/log4j.xml (60%)
copy {samza-log4j2/src/test => samza-test/src/main}/resources/log4j2.xml (71%)
copy LICENSE => samza-tools/LICENSE (100%)
copy NOTICE => samza-tools/NOTICE (100%)
