import org.apache.hadoop.hbase.avro.generated.AGet; //导入依赖的package包/类
static public Get agetToGet(AGet aget) throws IOException {
   Get get = new Get(Bytes.toBytes(aget.row));
   if (aget.columns != null) {
     for (AColumn acolumn : aget.columns) {
if (acolumn.qualifier != null) {
  get.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  get.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (aget.timestamp != null) {
     get.setTimeStamp(aget.timestamp);
   }
   if (aget.timerange != null) {
     get.setTimeRange(aget.timerange.minStamp, aget.timerange.maxStamp);
   }
   if (aget.maxVersions != null) {
     get.setMaxVersions(aget.maxVersions);
   }
   return get;
 }
 

import org.apache.hadoop.hbase.avro.generated.AGet; //导入依赖的package包/类
/**
 * Tests for adding, reading, and deleting data.
 *
 * @throws Exception
 */
@Test
public void testDML() throws Exception {
  AvroServer.HBaseImpl impl =
    new AvroServer.HBaseImpl(TEST_UTIL.getConfiguration());

  ATableDescriptor tableA = new ATableDescriptor();
  tableA.name = tableAname;
  AFamilyDescriptor familyA = new AFamilyDescriptor();
  familyA.name = familyAname;
  Schema familyArraySchema = Schema.createArray(AFamilyDescriptor.SCHEMA$);
  GenericArray<AFamilyDescriptor> families = new GenericData.Array<AFamilyDescriptor>(1, familyArraySchema);
  families.add(familyA);
  tableA.families = families;
  impl.createTable(tableA);
  assertEquals(impl.describeTable(tableAname).families.size(), 1);

  AGet getA = new AGet();
  getA.row = rowAname;
  Schema columnsSchema = Schema.createArray(AColumn.SCHEMA$);
  GenericArray<AColumn> columns = new GenericData.Array<AColumn>(1, columnsSchema);
  AColumn column = new AColumn();
  column.family = familyAname;
  column.qualifier = qualifierAname;
  columns.add(column);
  getA.columns = columns;
 
  assertFalse(impl.exists(tableAname, getA));

  APut putA = new APut();
  putA.row = rowAname;
  Schema columnValuesSchema = Schema.createArray(AColumnValue.SCHEMA$);
  GenericArray<AColumnValue> columnValues = new GenericData.Array<AColumnValue>(1, columnValuesSchema);
  AColumnValue acv = new AColumnValue();
  acv.family = familyAname;
  acv.qualifier = qualifierAname;
  acv.value = valueA;
  columnValues.add(acv);
  putA.columnValues = columnValues;

  impl.put(tableAname, putA);
  assertTrue(impl.exists(tableAname, getA));

  assertEquals(impl.get(tableAname, getA).entries.size(), 1);

  impl.disableTable(tableAname);
  impl.deleteTable(tableAname);
}