This is an automated email from the ASF dual-hosted git repository.
bharathkk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 5bef725 SAMZA-2410: Update ClusterBasedJobCoordinator config
retrieval logic from loader. (#1248)
add b379933 SAMZA-2404: [SEP-22] Container Placement Handler for
dispatching container placement messages between metastore and JobCoordinator
(#1227)
No new revisions were added by this update.
Summary of changes:
.../placement/ContainerPlacementMessage.java | 148 ++++++++++++
.../ContainerPlacementRequestMessage.java | 52 ++++
.../ContainerPlacementResponseMessage.java | 89 +++++++
.../clustermanager/ClusterBasedJobCoordinator.java | 51 +++-
.../clustermanager/ContainerProcessManager.java | 12 +
.../ContainerPlacementMessageObjectMapper.java | 128 ++++++++++
.../placement/ContainerPlacementMetadataStore.java | 269 +++++++++++++++++++++
.../ContainerPlacementRequestAllocator.java | 84 +++++++
.../TestContainerPlacementMetadataStore.java | 177 ++++++++++++++
.../TestContainerPlacementObjectMapper.java | 75 ++++++
10 files changed, 1082 insertions(+), 3 deletions(-)
create mode 100644
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java
create mode 100644
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementRequestMessage.java
create mode 100644
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java
create mode 100644
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMessageObjectMapper.java
create mode 100644
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java
create mode 100644
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementRequestAllocator.java
create mode 100644
samza-core/src/test/java/org/apache/samza/clustermanager/container/placement/TestContainerPlacementMetadataStore.java
create mode 100644
samza-core/src/test/java/org/apache/samza/clustermanager/container/placement/TestContainerPlacementObjectMapper.java
