ACCUMULO-1596 moved Mutator interface up to IZooReaderWriter
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/734cd505 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/734cd505 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/734cd505 Branch: refs/heads/ACCUMULO-1000 Commit: 734cd505d37f229d9c7204276059f33d3a7707ce Parents: 93f741e Author: Eric Newton <e...@apache.org> Authored: Mon Jul 22 13:44:48 2013 -0400 Committer: Eric Newton <e...@apache.org> Committed: Mon Jul 22 13:44:48 2013 -0400 ---------------------------------------------------------------------- .../org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java | 5 ++++- .../org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java | 4 ---- 2 files changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/734cd505/fate/src/main/java/org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java ---------------------------------------------------------------------- diff --git a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java index 5dcad23..a43ae7c 100644 --- a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java +++ b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/IZooReaderWriter.java @@ -18,7 +18,6 @@ package org.apache.accumulo.fate.zookeeper; import java.util.List; -import org.apache.accumulo.fate.zookeeper.ZooReaderWriter.Mutator; import org.apache.accumulo.fate.zookeeper.ZooUtil.NodeExistsPolicy; import org.apache.accumulo.fate.zookeeper.ZooUtil.NodeMissingPolicy; import org.apache.zookeeper.KeeperException; @@ -54,6 +53,10 @@ public interface IZooReaderWriter extends IZooReader { public abstract void delete(String path, int version) throws InterruptedException, KeeperException; + public interface Mutator { + byte[] mutate(byte[] currentValue) throws Exception; + } + public abstract byte[] mutate(String zPath, byte[] createValue, List<ACL> acl, Mutator mutator) throws Exception; public abstract boolean isLockHeld(ZooUtil.LockID lockID) throws KeeperException, InterruptedException; http://git-wip-us.apache.org/repos/asf/accumulo/blob/734cd505/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java ---------------------------------------------------------------------- diff --git a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java index 7800ec0..13c3c1a 100644 --- a/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java +++ b/fate/src/main/java/org/apache/accumulo/fate/zookeeper/ZooReaderWriter.java @@ -114,10 +114,6 @@ public class ZooReaderWriter extends ZooReader implements IZooReaderWriter { getZooKeeper().delete(path, version); } - public interface Mutator { - byte[] mutate(byte[] currentValue) throws Exception; - } - @Override public byte[] mutate(String zPath, byte[] createValue, List<ACL> acl, Mutator mutator) throws Exception { if (createValue != null) {