You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by sh...@apache.org on 2019/02/12 18:27:24 UTC
[samza] branch master updated (01ec54d -> fab6356)
This is an automated email from the ASF dual-hosted git repository.
shanthoosh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 01ec54d Support for types in Samza SQL UDF (#911)
new c0eda3a Initial commit.
new a4ee950 Address review comments.
new d8c61f6 Address review comments.
new 9677dce Code cleanup.
new 1495811 Rebase with the recent master before merge.
new fab6356 Merge pull request #874 from shanthoosh/SEP-5_left-over
The 1581 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:
.../container/grouper/stream/GrouperContext.java | 69 -----
.../apache/samza/container/LocalityManager.java | 20 +-
.../container/grouper/stream/SSPGrouperProxy.java | 50 ++--
.../grouper/task/TaskAssignmentManager.java | 6 +-
.../task/TaskPartitionAssignmentManager.java | 162 ++++++++++++
.../stream/CoordinatorStreamKeySerde.java | 7 +-
.../stream/CoordinatorStreamValueSerde.java | 7 +
.../stream/messages/SetContainerHostMapping.java | 17 --
.../stream/messages/SetTaskContainerMapping.java | 2 -
.../stream/messages/SetTaskPartitionMapping.java | 74 ++++++
.../samza/serializers/model/SamzaObjectMapper.java | 1 +
.../apache/samza/coordinator/JobModelManager.scala | 80 +++++-
.../grouper/stream/TestGroupByPartition.java | 75 +++---
.../stream/TestGroupBySystemStreamPartition.java | 105 ++++----
.../task/TestTaskPartitionAssignmentManager.java | 137 ++++++++++
.../samza/coordinator/TestJobModelManager.java | 63 ++++-
.../test/processor/TestStreamApplication.java | 20 +-
.../processor/TestZkLocalApplicationRunner.java | 283 +++++++++++++++++++--
18 files changed, 902 insertions(+), 276 deletions(-)
delete mode 100644 samza-api/src/main/java/org/apache/samza/container/grouper/stream/GrouperContext.java
create mode 100644 samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java
create mode 100644 samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskPartitionMapping.java
create mode 100644 samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskPartitionAssignmentManager.java