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; }
/** * 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); }