SAMZA-906: Host Affinity - Minimize task reassignment when container count changes
authorJacob Maes <jacob.maes@gmail.com>
Tue, 5 Apr 2016 00:26:25 +0000 (17:26 -0700)
committerYi Pan (Data Infrastructure) <nickpan47@gmail.com>
Tue, 5 Apr 2016 00:26:25 +0000 (17:26 -0700)
commit2a531b0bbfb11bfc1409f365d2d2fc920a7825ac
tree950b10d487dc56a4167f98f5b6d9936fc26400e5
parent3dce4935c3131340ab1e732c382742e086346f00
SAMZA-906: Host Affinity - Minimize task reassignment when container count changes
18 files changed:
checkstyle/import-control.xml
samza-core/src/main/java/org/apache/samza/container/LocalityManager.java
samza-core/src/main/java/org/apache/samza/container/grouper/task/BalancingTaskNameGrouper.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCountFactory.java [moved from samza-core/src/main/scala/org/apache/samza/container/grouper/task/GroupByContainerCountFactory.scala with 71% similarity]
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/coordinator/stream/AbstractCoordinatorStreamManager.java
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetContainerHostMapping.java
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskContainerMapping.java [new file with mode: 0644]
samza-core/src/main/scala/org/apache/samza/container/grouper/task/GroupByContainerCount.scala [deleted file]
samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestGroupByContainerCount.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/container/mock/ContainerMocks.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamWrappedConsumer.java
samza-core/src/test/java/org/apache/samza/storage/TestStorageRecovery.java
samza-core/src/test/scala/org/apache/samza/container/grouper/task/TestGroupByContainerCount.scala [deleted file]