1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.avro.generated.AResultEntry

Java 类org.apache.hadoop.hbase.avro.generated.AResultEntry 实例源码

项目：LCIndex-HBase-0.94.16    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：IRIndex    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：RStore    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：HBase-Research    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：hbase-0.94.8-qod    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：hbase-0.94.8-qod    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }
项目：hindex    文件：AvroUtil.java    
static public AResult resultToAResult(Result result) {
   AResult aresult = new AResult();
   byte[] row = result.getRow();
   aresult.row = ByteBuffer.wrap(row != null ? row : new byte[1]);
   Schema s = Schema.createArray(AResultEntry.SCHEMA$);
   GenericData.Array<AResultEntry> entries = null;
   List<KeyValue> resultKeyValues = result.list();
   if (resultKeyValues != null && resultKeyValues.size() > 0) {
     entries = new GenericData.Array<AResultEntry>(resultKeyValues.size(), s);
     for (KeyValue resultKeyValue : resultKeyValues) {
AResultEntry entry = new AResultEntry();
entry.family = ByteBuffer.wrap(resultKeyValue.getFamily());
entry.qualifier = ByteBuffer.wrap(resultKeyValue.getQualifier());
entry.value = ByteBuffer.wrap(resultKeyValue.getValue());
entry.timestamp = resultKeyValue.getTimestamp();
entries.add(entry);
     }
   } else {
     entries = new GenericData.Array<AResultEntry>(0, s);
   }
   aresult.entries = entries;
   return aresult;
 }