SAMZA-1385: Coordination utils factory with distributed lock
authorBoris Shkolnik <boryas@apache.org>
Tue, 29 Aug 2017 22:37:17 +0000 (15:37 -0700)
committerXinyu Liu <xiliu@xiliu-ld1.linkedin.biz>
Tue, 29 Aug 2017 22:37:17 +0000 (15:37 -0700)
commitdd07e07421bd57e0f927b8974131b949f5ac2e71
treed790a85a1a77a60febdbad6e1bb78551045cea87
parent81b4e6361f8c05e2a670ba6263c3786d0eea9f62
SAMZA-1385: Coordination utils factory with distributed lock

this PR includes some changes from another PR. I will re-merge it again, after the other PR is in.

Author: Boris Shkolnik <boryas@apache.org>

Reviewers: Xinyu Liu <xinyu@apache.org>

Closes #284 from sborya/CoordinationUtilsFactory_withDistributedLock
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java
samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java
samza-core/src/main/java/org/apache/samza/coordinator/DistributedLockWithState.java [new file with mode: 0644]
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedLock.java [new file with mode: 0644]
samza-core/src/test/java/org/apache/samza/runtime/TestApplicationRunnerMain.java
samza-core/src/test/java/org/apache/samza/runtime/TestLocalApplicationRunner.java