SAMZA-1128 : Remove dependency of debounce timer from the CoordinationUtils
authorNavina Ramesh <navina@apache.org>
Thu, 25 May 2017 00:46:12 +0000 (17:46 -0700)
committernramesh <nramesh@linkedin.com>
Thu, 25 May 2017 00:46:12 +0000 (17:46 -0700)
commit7355a45035306443544cf44e557322d9dc5fc0be
tree0392d785132ad733eb138bc3bd230a1d03448b5e
parent90f3ff6228355e27dfbc783b0beb96e3a430954f
SAMZA-1128 : Remove dependency of debounce timer from the CoordinationUtils

This patch addresses the following, apart from the main bug that barrier implementation uses a different scheduler that the Jobcoordinator's main thread.
* Removes CoordinationUtils#getBarrier, BarrierForVersionUpgrade interface
* Renamed ZkBarrierForVersionUpgrade to ZkBarrier and introduces a listener ZkBarrierListener
* Simplified the ZkBarrier class and its integration test

Author: Navina Ramesh <navina@apache.org>

Reviewers: Boris Shkolnik <boryas@apache.org>, Bharath Kumarasubramanian <bkumarasubramanian@linkedin.com>

Closes #195 from navina/SAMZA-1128
13 files changed:
samza-core/src/main/java/org/apache/samza/config/ZkConfig.java
samza-core/src/main/java/org/apache/samza/coordinator/BarrierForVersionUpgrade.java [deleted file]
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierListener.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/zk/ZkControllerImpl.java
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationServiceFactory.java
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java
samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java
samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java
samza-core/src/test/java/org/apache/samza/zk/TestZkBarrierForVersionUpgrade.java
samza-core/src/test/java/org/apache/samza/zk/TestZkKeyBuilder.java