org.apache.hadoop.hbase.filter.RowFilter.getCompareOperator()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.3k)|赞(0)|评价(0)|浏览(104)

本文整理了Java中org.apache.hadoop.hbase.filter.RowFilter.getCompareOperator方法的一些代码示例,展示了RowFilter.getCompareOperator的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RowFilter.getCompareOperator方法的具体详情如下:
包路径:org.apache.hadoop.hbase.filter.RowFilter
类名称:RowFilter
方法名:getCompareOperator

RowFilter.getCompareOperator介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

  1. @Override
  2. public boolean filterRowKey(Cell firstRowCell) {
  3. if (compareRow(getCompareOperator(), this.comparator, firstRowCell)) {
  4. this.filterOutRow = true;
  5. }
  6. return this.filterOutRow;
  7. }

代码示例来源:origin: apache/hbase

  1. @Test
  2. public void testRowFilter() throws IOException {
  3. String filterString = "RowFilter ( =, 'binary:regionse')";
  4. RowFilter rowFilter =
  5. doTestFilter(filterString, RowFilter.class);
  6. assertEquals(CompareOperator.EQUAL, rowFilter.getCompareOperator());
  7. assertTrue(rowFilter.getComparator() instanceof BinaryComparator);
  8. BinaryComparator binaryComparator = (BinaryComparator) rowFilter.getComparator();
  9. assertEquals("regionse", new String(binaryComparator.getValue(), StandardCharsets.UTF_8));
  10. }

代码示例来源:origin: apache/hbase

  1. @Test
  2. public void testWhileFilter() throws IOException {
  3. String filterString = " WHILE RowFilter ( !=, 'binary:row1')";
  4. WhileMatchFilter whileMatchFilter =
  5. doTestFilter(filterString, WhileMatchFilter.class);
  6. assertTrue(whileMatchFilter.getFilter() instanceof RowFilter);
  7. RowFilter rowFilter = (RowFilter) whileMatchFilter.getFilter();
  8. assertEquals(CompareOperator.NOT_EQUAL, rowFilter.getCompareOperator());
  9. assertTrue(rowFilter.getComparator() instanceof BinaryComparator);
  10. BinaryComparator binaryComparator = (BinaryComparator) rowFilter.getComparator();
  11. assertEquals("row1", new String(binaryComparator.getValue(), StandardCharsets.UTF_8));
  12. }

代码示例来源:origin: org.apache.hbase/hbase-client

  1. @Override
  2. public boolean filterRowKey(Cell firstRowCell) {
  3. if (compareRow(getCompareOperator(), this.comparator, firstRowCell)) {
  4. this.filterOutRow = true;
  5. }
  6. return this.filterOutRow;
  7. }

代码示例来源:origin: com.aliyun.hbase/alihbase-client

  1. @Override
  2. public boolean filterRowKey(Cell firstRowCell) {
  3. if (compareRow(getCompareOperator(), this.comparator, firstRowCell)) {
  4. this.filterOutRow = true;
  5. }
  6. return this.filterOutRow;
  7. }

代码示例来源:origin: org.apache.hbase/hbase-server

  1. @Test
  2. public void testRowFilter() throws IOException {
  3. String filterString = "RowFilter ( =, 'binary:regionse')";
  4. RowFilter rowFilter =
  5. doTestFilter(filterString, RowFilter.class);
  6. assertEquals(CompareOperator.EQUAL, rowFilter.getCompareOperator());
  7. assertTrue(rowFilter.getComparator() instanceof BinaryComparator);
  8. BinaryComparator binaryComparator = (BinaryComparator) rowFilter.getComparator();
  9. assertEquals("regionse", new String(binaryComparator.getValue(), StandardCharsets.UTF_8));
  10. }

代码示例来源:origin: org.apache.hbase/hbase-server

  1. @Test
  2. public void testWhileFilter() throws IOException {
  3. String filterString = " WHILE RowFilter ( !=, 'binary:row1')";
  4. WhileMatchFilter whileMatchFilter =
  5. doTestFilter(filterString, WhileMatchFilter.class);
  6. assertTrue(whileMatchFilter.getFilter() instanceof RowFilter);
  7. RowFilter rowFilter = (RowFilter) whileMatchFilter.getFilter();
  8. assertEquals(CompareOperator.NOT_EQUAL, rowFilter.getCompareOperator());
  9. assertTrue(rowFilter.getComparator() instanceof BinaryComparator);
  10. BinaryComparator binaryComparator = (BinaryComparator) rowFilter.getComparator();
  11. assertEquals("row1", new String(binaryComparator.getValue(), StandardCharsets.UTF_8));
  12. }

相关文章