本文整理了Java中org.apache.accumulo.fate.ZooStore.deserialize()方法的一些代码示例，展示了ZooStore.deserialize()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooStore.deserialize()方法的具体详情如下：
包路径：org.apache.accumulo.fate.ZooStore
类名称：ZooStore
方法名：deserialize

ZooStore.deserialize介绍

暂无

代码示例

代码示例来源：origin: apache/accumulo

@Override
public Serializable getProperty(long tid, String prop) {
 verifyReserved(tid);
 try {
  byte[] data = zk.getData(getTXPath(tid) + "/prop_" + prop, null);
  if (data[0] == 'O') {
   byte[] sera = new byte[data.length - 2];
   System.arraycopy(data, 2, sera, 0, sera.length);
   return (Serializable) deserialize(sera);
  } else if (data[0] == 'S') {
   return new String(data, 2, data.length - 2, UTF_8);
  } else {
   throw new IllegalStateException("Bad property data " + prop);
  }
 } catch (NoNodeException nne) {
  return null;
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: apache/accumulo

ser = zk.getData(txpath + "/" + child, null);
 @SuppressWarnings("unchecked")
 ReadOnlyRepo<T> repo = (ReadOnlyRepo<T>) deserialize(ser);
 dops.add(repo);
} catch (KeeperException.NoNodeException e) {

代码示例来源：origin: apache/accumulo

@SuppressWarnings("unchecked")
@Override
public Repo<T> top(long tid) {
 verifyReserved(tid);
 for (int i = 0; i < RETRIES; i++) {
  String txpath = getTXPath(tid);
  try {
   String top;
   try {
    top = findTop(txpath);
    if (top == null) {
     return null;
    }
   } catch (KeeperException.NoNodeException ex) {
    throw new RuntimeException(ex);
   }
   byte[] ser = zk.getData(txpath + "/" + top, null);
   return (Repo<T>) deserialize(ser);
  } catch (KeeperException.NoNodeException ex) {
   log.debug("zookeeper error reading " + txpath + ": " + ex, ex);
   sleepUninterruptibly(100, TimeUnit.MILLISECONDS);
   continue;
  } catch (Exception e) {
   throw new RuntimeException(e);
  }
 }
 return null;
}

代码示例来源：origin: org.apache.accumulo/accumulo-fate

@Override
public Serializable getProperty(long tid, String prop) {
 verifyReserved(tid);
 try {
  byte[] data = zk.getData(getTXPath(tid) + "/prop_" + prop, null);
  if (data[0] == 'O') {
   byte[] sera = new byte[data.length - 2];
   System.arraycopy(data, 2, sera, 0, sera.length);
   return (Serializable) deserialize(sera);
  } else if (data[0] == 'S') {
   return new String(data, 2, data.length - 2, UTF_8);
  } else {
   throw new IllegalStateException("Bad property data " + prop);
  }
 } catch (NoNodeException nne) {
  return null;
 } catch (Exception e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-fate

ser = zk.getData(txpath + "/" + child, null);
 @SuppressWarnings("unchecked")
 ReadOnlyRepo<T> repo = (ReadOnlyRepo<T>) deserialize(ser);
 dops.add(repo);
} catch (KeeperException.NoNodeException e) {

代码示例来源：origin: org.apache.accumulo/accumulo-fate

@SuppressWarnings("unchecked")
@Override
public Repo<T> top(long tid) {
 verifyReserved(tid);
 for (int i = 0; i < RETRIES; i++) {
  String txpath = getTXPath(tid);
  try {
   String top;
   try {
    top = findTop(txpath);
    if (top == null) {
     return null;
    }
   } catch (KeeperException.NoNodeException ex) {
    throw new RuntimeException(ex);
   }
   byte[] ser = zk.getData(txpath + "/" + top, null);
   return (Repo<T>) deserialize(ser);
  } catch (KeeperException.NoNodeException ex) {
   log.debug("zookeeper error reading " + txpath + ": " + ex.toString(), ex);
   sleepUninterruptibly(100, TimeUnit.MILLISECONDS);
   continue;
  } catch (Exception e) {
   throw new RuntimeException(e);
  }
 }
 return null;
}