Java 类org.apache.hadoop.hbase.filter.ColumnPaginationFilter 实例源码

项目：aliyun-tablestore-hbase-client 文件：OGet.java

/**
 * For core use. DO NOT USE.
 */
public SingleRowQueryCriteria toOTSParameter(String tableName) {
  PrimaryKey primaryKey = OTSUtil.toPrimaryKey(getRow(), OTSConstants.PRIMARY_KEY_NAME);
  SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, primaryKey);
  criteria.setMaxVersions(getMaxVersions());
  criteria.setTimeRange(OTSUtil.toTimeRange(getTimeRange()));
  for (byte[] col : columnsToGet) {
    criteria.addColumnsToGet(Bytes.toString(col));
  }
  if (filter != null) {
    if (filter instanceof OColumnPaginationFilter) {
      OColumnPaginationFilter oFilter = (OColumnPaginationFilter)filter;
      com.alicloud.openservices.tablestore.model.filter.ColumnPaginationFilter columnPaginationFilter =
              new com.alicloud.openservices.tablestore.model.filter.ColumnPaginationFilter(oFilter.getLimit());
      if (oFilter.getColumnOffset() == null) {
        columnPaginationFilter.setOffset(oFilter.getOffset());
      } else {
        criteria.setStartColumn(Bytes.toString(oFilter.getColumnOffset()));
      }
      criteria.setFilter(columnPaginationFilter);
    } else {
      criteria.setFilter(OTSUtil.toFilter(getFilter()));
    }
  }
  return criteria;
}

项目：cloud-bigtable-client 文件：ColumnPaginationFilterAdapter.java

@Override
public RowFilter adapt(FilterAdapterContext context, ColumnPaginationFilter filter)
    throws IOException {
  if (filter.getColumnOffset() != null) {
    byte[] family = context.getScan().getFamilies()[0];
    // Include all cells starting at the qualifier scan.getColumnOffset()
    // up to limit cells.
    return createChain(
        filter,
        RowFilter.newBuilder()
            .setColumnRangeFilter(
                ColumnRange.newBuilder()
                    .setFamilyName(Bytes.toString(family))
                    .setStartQualifierInclusive(
                        ByteString.copyFrom(filter.getColumnOffset()))));
  } else if (filter.getOffset() > 0) {
    // Include starting at an integer offset up to limit cells.
    return createChain(
        filter,
        RowFilter.newBuilder()
            .setCellsPerRowOffsetFilter(filter.getOffset()));
  } else {
    // No meaningful offset supplied.
    return createChain(filter, null);
  }
}

项目：cloud-bigtable-client 文件：TestColumnPaginationFilterAdapter.java

@Test
public void integerLimitsAreApplied() throws IOException {
  ColumnPaginationFilter filter = new ColumnPaginationFilter(10, 20);
  RowFilter adaptedFilter = adapter.adapt(
      new FilterAdapterContext(new Scan()), filter);
  Assert.assertEquals(
      RowFilter.newBuilder()
          .setChain(
              Chain.newBuilder()
                  .addFilters(RowFilter.newBuilder()
                      .setCellsPerColumnLimitFilter(1))
                  .addFilters(RowFilter.newBuilder()
                      .setCellsPerRowOffsetFilter(20))
                  .addFilters(RowFilter.newBuilder()
                      .setCellsPerRowLimitFilter(10)))
          .build(),
      adaptedFilter);
}

项目：cloud-bigtable-client 文件：TestColumnPaginationFilterAdapter.java

@Test
public void zeroOffsetLimitIsSupported() throws IOException {
  ColumnPaginationFilter filter = new ColumnPaginationFilter(10, 0);
  RowFilter adaptedFilter = adapter.adapt(
      new FilterAdapterContext(new Scan()), filter);
  Assert.assertEquals(
      RowFilter.newBuilder()
          .setChain(
              Chain.newBuilder()
                  .addFilters(RowFilter.newBuilder()
                      .setCellsPerColumnLimitFilter(1))
                  .addFilters(RowFilter.newBuilder()
                      .setCellsPerRowLimitFilter(10)))
          .build(),
      adaptedFilter);
}

项目：cloud-bigtable-client 文件：TestFilters.java

/**
 * Requirement 9.2
 */
@Test
@Category(KnownGap.class)
public void testColumnPaginationFilter_StartingAtParticularQualifier() throws Exception {
  Table table = getConnection().getTable(TABLE_NAME);
  byte[] rowKey = dataHelper.randomData("testrow-");
  Put put = new Put(rowKey);
  byte[] value = Bytes.toBytes("someval");
  put.addColumn(COLUMN_FAMILY, Bytes.toBytes("A"), value);
  put.addColumn(COLUMN_FAMILY, Bytes.toBytes("AA"), value);
  put.addColumn(COLUMN_FAMILY, Bytes.toBytes("B"), value);
  put.addColumn(COLUMN_FAMILY, Bytes.toBytes("BB"), value);
  put.addColumn(COLUMN_FAMILY, Bytes.toBytes("C"), value);
  table.put(put);

  // Filter and test
  Filter filter = new ColumnPaginationFilter(3, Bytes.toBytes("AA"));
  Get get = new Get(rowKey).setFilter(filter).setMaxVersions(10);
  Result result = table.get(get);
  Assert.assertEquals("Should have filtered to N columns", 3, result.size());
  Assert.assertEquals("AA", Bytes.toString(CellUtil.cloneQualifier(result.rawCells()[0])));
  Assert.assertEquals("B", Bytes.toString(CellUtil.cloneQualifier(result.rawCells()[1])));
  Assert.assertEquals("BB", Bytes.toString(CellUtil.cloneQualifier(result.rawCells()[2])));

  table.close();
}

项目：hbase-secondary-index 文件：HBaseManager.java

public void testGet() throws IOException {
    long st = System.currentTimeMillis();
    Get get = new Get(
            Bytes.toBytes("{1F591795-74DE-EB70-0245-0E4465C72CFA}"));
    get.addColumn(Bytes.toBytes("bhvr"), Bytes.toBytes("vvmid"));
    get.setMaxVersions(100);
    // get.setTimeRange(1354010844711L - 12000L, 1354010844711L);

    // get.setTimeStamp(1354700700000L);

    Filter filter = new ColumnPaginationFilter(1, 10);
    get.setFilter(filter);

    Result dbResult = table.get(get);

    System.out.println("result=" + dbResult.toString());

    long en2 = System.currentTimeMillis();
    System.out.println("Total Time: " + (en2 - st) + " ms");

}