@Test public void columnQualifierIsSet() throws IOException { Get get = makeValidGet(dataHelper.randomData(PREFIX_DATA)); get.addColumn(Bytes.toBytes(FAMILY_ID), Bytes.toBytes(QUALIFIER_ID)); getAdapter.adapt(get, throwingReadHooks, query); Assert.assertEquals( FILTERS .chain() .filter(FILTERS.family().regex(FAMILY_ID)) .filter(FILTERS.qualifier().regex(QUALIFIER_ID)) .toProto(), query.toProto(requestContext).getFilter()); }
@Override public void adapt(Get operation, ReadHooks readHooks, Query query) { Scan operationAsScan = new Scan(addKeyOnlyFilter(operation)); scanAdapter.throwIfUnsupportedScan(operationAsScan); query .filter(scanAdapter.buildFilter(operationAsScan, readHooks)) .rowKey(ByteString.copyFrom(operation.getRow())); }
GetAdapter implements ReadOperationAdapter<Get> { @Override public void adapt(Get operation, ReadHooks readHooks, Query query) { Scan operationAsScan = new Scan(addKeyOnlyFilter(operation)); scanAdapter.throwIfUnsupportedScan(operationAsScan); query .filter(scanAdapter.buildFilter(operationAsScan, readHooks)) .rowKey(ByteString.copyFrom(operation.getRow())); } }
GetAdapter implements ReadOperationAdapter<Get> { @Override public void adapt(Get operation, ReadHooks readHooks, Query query) { Scan operationAsScan = new Scan(addKeyOnlyFilter(operation)); scanAdapter.throwIfUnsupportedScan(operationAsScan); query .filter(scanAdapter.buildFilter(operationAsScan, readHooks)) .rowKey(ByteString.copyFrom(operation.getRow())); } GetAdapter(ScanAdapter scanAdapter); }
GetAdapter implements ReadOperationAdapter<Get> { @Override public void adapt(Get operation, ReadHooks readHooks, Query query) { Scan operationAsScan = new Scan(addKeyOnlyFilter(operation)); scanAdapter.throwIfUnsupportedScan(operationAsScan); query .filter(scanAdapter.buildFilter(operationAsScan, readHooks)) .rowKey(ByteString.copyFrom(operation.getRow())); } GetAdapter(ScanAdapter scanAdapter); static Get setCheckExistenceOnly(Get get); @Override void adapt(Get operation, ReadHooks readHooks, Query query); Filters.Filter buildFilter(Get operation); }
GetAdapter implements ReadOperationAdapter<Get> { @Override public void adapt(Get operation, ReadHooks readHooks, Query query) { Scan operationAsScan = new Scan(addKeyOnlyFilter(operation)); scanAdapter.throwIfUnsupportedScan(operationAsScan); query .filter(scanAdapter.buildFilter(operationAsScan, readHooks)) .rowKey(ByteString.copyFrom(operation.getRow())); } GetAdapter(ScanAdapter scanAdapter); static Get setCheckExistenceOnly(Get get); @Override void adapt(Get operation, ReadHooks readHooks, Query query); Filters.Filter buildFilter(Get operation);  }