1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.util.Classes

Java 类org.apache.hadoop.hbase.util.Classes 实例源码

项目：LCIndex-HBase-0.94.16    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：IRIndex    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：RStore    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：HBase-Research    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：hbase-0.94.8-qod    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：hbase-0.94.8-qod    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：hindex    文件：Exec.java    
@Override
public void readFields(DataInput in) throws IOException {
  // fields for Invocation
  methodName = in.readUTF();
  parameters = new Object[in.readInt()];
  parameterClasses = new Class[parameters.length];
  HbaseObjectWritable objectWritable = new HbaseObjectWritable();
  for (int i = 0; i < parameters.length; i++) {
    parameters[i] = HbaseObjectWritable.readObject(in, objectWritable,
      this.conf);
    String parameterClassName = in.readUTF();
    try {
      parameterClasses[i] = Classes.extendedForName(parameterClassName);
    } catch (ClassNotFoundException e) {
      throw new IOException("Couldn't find class: " + parameterClassName);
    }
  }
  // fields for Exec
  referenceRow = Bytes.readByteArray(in);
  protocolName = in.readUTF();
}
项目：LCIndex-HBase-0.94.16    文件：Scan.java    
public void readFields(final DataInput in) throws IOException {
  int version = in.readByte();
  if (version > (int) SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if (in.readBoolean()) {
    this.filter = Classes.createWritableForName(Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap = new TreeMap<byte[], NavigableSet<byte[]>>(Bytes.BYTES_COMPARATOR);
  for (int i = 0; i < numFamilies; i++) {
    byte[] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte[]> set = new TreeSet<byte[]>(Bytes.BYTES_COMPARATOR);
    for (int j = 0; j < numColumns; j++) {
      byte[] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：LCIndex-HBase-0.94.16    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：IRIndex    文件：Scan.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > (int)SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if(in.readBoolean()) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [], NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte []> set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
    for(int j=0; j<numColumns; j++) {
      byte [] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：IRIndex    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：HBase-Research    文件：Scan.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > (int)SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if(in.readBoolean()) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [], NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte []> set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
    for(int j=0; j<numColumns; j++) {
      byte [] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：HBase-Research    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：hbase-0.94.8-qod    文件：Scan.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > (int)SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if(in.readBoolean()) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [], NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte []> set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
    for(int j=0; j<numColumns; j++) {
      byte [] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：hbase-0.94.8-qod    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：hbase-0.94.8-qod    文件：Scan.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > (int)SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if(in.readBoolean()) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [], NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte []> set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
    for(int j=0; j<numColumns; j++) {
      byte [] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：hbase-0.94.8-qod    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：hindex    文件：Scan.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > (int)SCAN_VERSION) {
    throw new IOException("version not supported");
  }
  this.startRow = Bytes.readByteArray(in);
  this.stopRow = Bytes.readByteArray(in);
  this.maxVersions = in.readInt();
  this.batch = in.readInt();
  this.caching = in.readInt();
  this.cacheBlocks = in.readBoolean();
  if(in.readBoolean()) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [], NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    int numColumns = in.readInt();
    TreeSet<byte []> set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
    for(int j=0; j<numColumns; j++) {
      byte [] qualifier = Bytes.readByteArray(in);
      set.add(qualifier);
    }
    this.familyMap.put(family, set);
  }

  if (version > 1) {
    readAttributes(in);
  }
}
项目：hindex    文件：Get.java    
public void readFields(final DataInput in)
throws IOException {
  int version = in.readByte();
  if (version > GET_VERSION) {
    throw new IOException("unsupported version");
  }
  this.row = Bytes.readByteArray(in);
  this.lockId = in.readLong();
  this.maxVersions = in.readInt();
  boolean hasFilter = in.readBoolean();
  if (hasFilter) {
    this.filter = Classes.createWritableForName(
      Bytes.toString(Bytes.readByteArray(in)));
    this.filter.readFields(in);
  }
  this.cacheBlocks = in.readBoolean();
  this.tr = new TimeRange();
  tr.readFields(in);
  int numFamilies = in.readInt();
  this.familyMap =
    new TreeMap<byte [],NavigableSet<byte []>>(Bytes.BYTES_COMPARATOR);
  for(int i=0; i<numFamilies; i++) {
    byte [] family = Bytes.readByteArray(in);
    boolean hasColumns = in.readBoolean();
    NavigableSet<byte []> set = null;
    if(hasColumns) {
      int numColumns = in.readInt();
      set = new TreeSet<byte []>(Bytes.BYTES_COMPARATOR);
      for(int j=0; j<numColumns; j++) {
        byte [] qualifier = Bytes.readByteArray(in);
        set.add(qualifier);
      }
    }
    this.familyMap.put(family, set);
  }
  readAttributes(in);
}
项目：LCIndex-HBase-0.94.16    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：LCIndex-HBase-0.94.16    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：IRIndex    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：IRIndex    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：HBase-Research    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：HBase-Research    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hbase-0.94.8-qod    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hbase-0.94.8-qod    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hbase-0.94.8-qod    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hbase-0.94.8-qod    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hindex    文件：WhileMatchFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}
项目：hindex    文件：SkipFilter.java    
public void readFields(DataInput in) throws IOException {
  this.filter = Classes.createForName(in.readUTF());
  this.filter.readFields(in);
}