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

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

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

RowFilter.<init>介绍

[英]Writable constructor, do not use.
[中]可写构造函数，请勿使用。

代码示例

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

  1. public static Filter createFilterFromArguments(ArrayList<byte []> filterArguments) {
  2.  @SuppressWarnings("rawtypes") // for arguments
  3.  ArrayList arguments = CompareFilter.extractArguments(filterArguments);
  4.  CompareOperator compareOp = (CompareOperator)arguments.get(0);
  5.  ByteArrayComparable comparator = (ByteArrayComparable)arguments.get(1);
  6.  return new RowFilter(compareOp, comparator);
  7. }

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

  1. private static Filter getRowFilter(String[] args) {
  2.  Filter rowFilter = null;
  3.  String filterCriteria = (args.length > 3) ? args[3]: null;
  4.  if (filterCriteria == null) return null;
  5.  if (filterCriteria.startsWith("^")) {
  6.   String regexPattern = filterCriteria.substring(1, filterCriteria.length());
  7.   rowFilter = new RowFilter(CompareOperator.EQUAL, new RegexStringComparator(regexPattern));
  8.  } else {
  9.   rowFilter = new PrefixFilter(Bytes.toBytesBinary(filterCriteria));
  10.  }
  11.  return rowFilter;
  12. }

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

  1. private static Filter getExportFilter(String[] args) {
  2.  Filter exportFilter;
  3.  String filterCriteria = (args.length > 5) ? args[5]: null;
  4.  if (filterCriteria == null) return null;
  5.  if (filterCriteria.startsWith("^")) {
  6.   String regexPattern = filterCriteria.substring(1, filterCriteria.length());
  7.   exportFilter = new RowFilter(CompareOperator.EQUAL, new RegexStringComparator(regexPattern));
  8.  } else {
  9.   exportFilter = new PrefixFilter(Bytes.toBytesBinary(filterCriteria));
  10.  }
  11.  return exportFilter;
  12. }

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

  1. private Scan createScanWithRowFilter(final byte [] key,
  2.   final byte [] startRow, CompareOperator op) {
  3.  // Make sure key is of some substance... non-null and > than first key.
  4.  assertTrue(key != null && key.length > 0 &&
  5.   Bytes.BYTES_COMPARATOR.compare(key, new byte [] {'a', 'a', 'a'}) >= 0);
  6.  LOG.info("Key=" + Bytes.toString(key));
  7.  Scan s = startRow == null? new Scan(): new Scan(startRow);
  8.  Filter f = new RowFilter(op, new BinaryComparator(key));
  9.  f = new WhileMatchFilter(f);
  10.  s.setFilter(f);
  11.  return s;
  12. }

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

  1. protected void initialize(JobConf job, String table) throws IOException {
  2.  Connection connection = ConnectionFactory.createConnection(HBaseConfiguration.create(job));
  3.  TableName tableName = TableName.valueOf(table);
  4.  // mandatory
  5.  initializeTable(connection, tableName);
  6.  byte[][] inputColumns = new byte [][] { Bytes.toBytes("columnA"),
  7.   Bytes.toBytes("columnB") };
  8.  // mandatory
  9.  setInputColumns(inputColumns);
  10.  Filter exampleFilter =
  11.   new RowFilter(CompareOperator.EQUAL, new RegexStringComparator("aa.*"));
  12.  // optional
  13.  setRowFilter(exampleFilter);
  14. }

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

  1. @Override
  2. protected void initialize(JobContext job) throws IOException {
  3.  Connection connection = ConnectionFactory.createConnection(HBaseConfiguration.create(
  4.    job.getConfiguration()));
  5.  TableName tableName = TableName.valueOf("exampleTable");
  6.  // mandatory
  7.  initializeTable(connection, tableName);
  8.  byte[][] inputColumns = new byte [][] { Bytes.toBytes("columnA"),
  9.   Bytes.toBytes("columnB") };
  10.  //optional
  11.  Scan scan = new Scan();
  12.  for (byte[] family : inputColumns) {
  13.   scan.addFamily(family);
  14.  }
  15.  Filter exampleFilter =
  16.   new RowFilter(CompareOperator.EQUAL, new RegexStringComparator("aa.*"));
  17.  scan.setFilter(exampleFilter);
  18.  setScan(scan);
  19. }

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

  1. @Override
  2.  public void configure(JobConf job) {
  3.   try {
  4.    Connection connection = ConnectionFactory.createConnection(HBaseConfiguration.create(job));
  5.    TableName tableName = TableName.valueOf("exampleJobConfigurableTable");
  6.    // mandatory
  7.    initializeTable(connection, tableName);
  8.    byte[][] inputColumns = new byte [][] { Bytes.toBytes("columnA"),
  9.     Bytes.toBytes("columnB") };
  10.    //optional
  11.    Scan scan = new Scan();
  12.    for (byte[] family : inputColumns) {
  13.     scan.addFamily(family);
  14.    }
  15.    Filter exampleFilter =
  16.     new RowFilter(CompareOperator.EQUAL, new RegexStringComparator("aa.*"));
  17.    scan.setFilter(exampleFilter);
  18.    setScan(scan);
  19.   } catch (IOException exception) {
  20.    throw new RuntimeException("Failed to initialize.", exception);
  21.   }
  22.  }
  23. }

代码示例来源：origin: apache/hive

  1. filters.add(new RowFilter(CompareOp.GREATER_OR_EQUAL, new BinaryComparator(valueAsBytes)));
  2. } else if (comparisonOp.endsWith("UDFOPGreaterThan")) {
  3.  filters.add(new RowFilter(CompareOp.GREATER, new BinaryComparator(valueAsBytes)));
  4. } else if (comparisonOp.endsWith("UDFOPEqualOrLessThan")) {
  5.  filters.add(new RowFilter(CompareOp.LESS_OR_EQUAL, new BinaryComparator(valueAsBytes)));
  6. } else if (comparisonOp.endsWith("UDFOPLessThan")) {
  7.  filters.add(new RowFilter(CompareOp.LESS, new BinaryComparator(valueAsBytes)));
  8. } else {
  9.  throw new IOException(comparisonOp + " is not a supported comparison operator");

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

  1. @Test public void testCompareFilter() throws Exception {
  2.  Filter f = new RowFilter(CompareOperator.EQUAL,
  3.   new BinaryComparator(Bytes.toBytes("testRowOne-2")));
  4.  byte [] bytes = f.toByteArray();
  5.  Filter ff = RowFilter.parseFrom(bytes);
  6.  assertNotNull(ff);
  7. }

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

  1. @Override
  2. public void configure(JobConf job) {
  3.  try {
  4.   Connection connection = ConnectionFactory.createConnection(job);
  5.   Table exampleTable = connection.getTable(TableName.valueOf("exampleDeprecatedTable"));
  6.   // mandatory
  7.   initializeTable(connection, exampleTable.getName());
  8.   byte[][] inputColumns = new byte [][] { Bytes.toBytes("columnA"),
  9.    Bytes.toBytes("columnB") };
  10.   // mandatory
  11.   setInputColumns(inputColumns);
  12.   Filter exampleFilter =
  13.    new RowFilter(CompareOperator.EQUAL, new RegexStringComparator("aa.*"));
  14.   // optional
  15.   setRowFilter(exampleFilter);
  16.  } catch (IOException exception) {
  17.   throw new RuntimeException("Failed to configure for job.", exception);
  18.  }
  19. }

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

  1. @Override
  2. public void configure(JobConf job) {
  3.  try {
  4.   Connection connection = ConnectionFactory.createConnection(job);
  5.   Table exampleTable = connection.getTable(TableName.valueOf(("exampleDeprecatedTable")));
  6.   // mandatory
  7.   initializeTable(connection, exampleTable.getName());
  8.   byte[][] inputColumns = new byte [][] { Bytes.toBytes("columnA"),
  9.    Bytes.toBytes("columnB") };
  10.   // optional
  11.   Scan scan = new Scan();
  12.   for (byte[] family : inputColumns) {
  13.    scan.addFamily(family);
  14.   }
  15.   Filter exampleFilter =
  16.    new RowFilter(CompareOperator.EQUAL, new RegexStringComparator("aa.*"));
  17.   scan.setFilter(exampleFilter);
  18.   setScan(scan);
  19.  } catch (IOException exception) {
  20.   throw new RuntimeException("Failed to configure for job.", exception);
  21.  }
  22. }

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

  1. @Test
  2. public void testJira6912() throws Exception {
  3.  final TableName tableName = TableName.valueOf(name.getMethodName());
  4.  Table foo = TEST_UTIL.createTable(tableName, new byte[][] {FAMILY}, 10);
  5.  List<Put> puts = new ArrayList<Put>();
  6.  for (int i=0;i !=100; i++){
  7.   Put put = new Put(Bytes.toBytes(i));
  8.   put.addColumn(FAMILY, FAMILY, Bytes.toBytes(i));
  9.   puts.add(put);
  10.  }
  11.  foo.put(puts);
  12.  // If i comment this out it works
  13.  TEST_UTIL.flush();
  14.  Scan scan = new Scan();
  15.  scan.setStartRow(Bytes.toBytes(1));
  16.  scan.setStopRow(Bytes.toBytes(3));
  17.  scan.addColumn(FAMILY, FAMILY);
  18.  scan.setFilter(new RowFilter(CompareOperator.NOT_EQUAL,
  19.    new BinaryComparator(Bytes.toBytes(1))));
  20.  ResultScanner scanner = foo.getScanner(scan);
  21.  Result[] bar = scanner.next(100);
  22.  assertEquals(1, bar.length);
  23. }

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

  1. @Test
  2. public void testFilterList() throws Exception {
  3.  // empty filter list
  4.  FilterList filterList = new FilterList(new LinkedList<>());
  5.  assertTrue(filterList.areSerializedFieldsEqual(
  6.   ProtobufUtil.toFilter(ProtobufUtil.toFilter(filterList))));
  7.  // non-empty filter list
  8.  LinkedList<Filter> list = new LinkedList<>();
  9.  list.add(new ColumnCountGetFilter(1));
  10.  list.add(new RowFilter(CompareOperator.EQUAL,
  11.   new SubstringComparator("testFilterList")));
  12.  assertTrue(filterList.areSerializedFieldsEqual(
  13.   ProtobufUtil.toFilter(ProtobufUtil.toFilter(filterList))));
  14. }

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

  1. @Test
  2. public void testFilterList() throws IOException {
  3.  // Test getting a single row, single key using Row, Qualifier, and Value
  4.  // regular expression and substring filters
  5.  // Use must pass all
  6.  List<Filter> filters = new ArrayList<>();
  7.  filters.add(new RowFilter(CompareOperator.EQUAL, new RegexStringComparator(".+-2")));
  8.  filters.add(new QualifierFilter(CompareOperator.EQUAL, new RegexStringComparator(".+-2")));
  9.  filters.add(new ValueFilter(CompareOperator.EQUAL, new SubstringComparator("One")));
  10.  Filter f = new FilterList(Operator.MUST_PASS_ALL, filters);
  11.  Scan s = new Scan();
  12.  s.addFamily(FAMILIES[0]);
  13.  s.setFilter(f);
  14.  KeyValue [] kvs = {
  15.    new KeyValue(ROWS_ONE[2], FAMILIES[0], QUALIFIERS_ONE[2], VALUES[0])
  16.  };
  17.  verifyScanFull(s, kvs);
  18.  // Test getting everything with a MUST_PASS_ONE filter including row, qf, val
  19.  // regular expression and substring filters
  20.  filters.clear();
  21.  filters.add(new RowFilter(CompareOperator.EQUAL, new RegexStringComparator(".+Two.+")));
  22.  filters.add(new QualifierFilter(CompareOperator.EQUAL, new RegexStringComparator(".+-2")));
  23.  filters.add(new ValueFilter(CompareOperator.EQUAL, new SubstringComparator("One")));
  24.  f = new FilterList(Operator.MUST_PASS_ONE, filters);
  25.  s = new Scan();
  26.  s.setFilter(f);
  27.  verifyScanNoEarlyOut(s, this.numRows, this.colsPerRow);
  28. }

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

  1. new RowFilter(CompareOperator.EQUAL, new BinaryComparator(Bytes.toBytes("xyz")));
  2. testRowsFilteredMetric(baseScan, filter, ROWS.length);
  3. filters.add(new RowFilter(CompareOperator.EQUAL, new BinaryComparator(ROWS[0])));
  4. filters.add(new RowFilter(CompareOperator.EQUAL, new BinaryComparator(ROWS[3])));
  5. int numberOfMatchingRowFilters = filters.size();
  6. filter = new FilterList(Operator.MUST_PASS_ONE, filters);

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

  1. filters.add(new RowFilter(CompareOperator.EQUAL,
  2.  new RegexStringComparator(".+-2")));
  3. filters.add(new QualifierFilter(CompareOperator.EQUAL,
  4. filters.add(new RowFilter(CompareOperator.EQUAL,
  5.  new RegexStringComparator(".+Two.+")));
  6. filters.add(new QualifierFilter(CompareOperator.EQUAL,

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

  1. @Test
  2. public void testRowFilter() throws Exception {
  3.  RowFilter rowFilter = new RowFilter(CompareOperator.EQUAL,
  4.   new SubstringComparator("testRowFilter"));
  5.  assertTrue(rowFilter.areSerializedFieldsEqual(
  6.   ProtobufUtil.toFilter(ProtobufUtil.toFilter(rowFilter))));
  7. }

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

  1. new RowFilter(CompareOperator.EQUAL, new BinaryComparator(Bytes.toBytes("xyz")));
  2. scan = new Scan(baseScan);
  3. scan.setFilter(filter);

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

  1. /**
  2.  * @param pbBytes A pb serialized {@link RowFilter} instance
  3.  * @return An instance of {@link RowFilter} made from <code>bytes</code>
  4.  * @throws DeserializationException
  5.  * @see #toByteArray
  6.  */
  7. public static RowFilter parseFrom(final byte [] pbBytes)
  8. throws DeserializationException {
  9.  FilterProtos.RowFilter proto;
  10.  try {
  11.   proto = FilterProtos.RowFilter.parseFrom(pbBytes);
  12.  } catch (InvalidProtocolBufferException e) {
  13.   throw new DeserializationException(e);
  14.  }
  15.  final CompareOperator valueCompareOp =
  16.   CompareOperator.valueOf(proto.getCompareFilter().getCompareOp().name());
  17.  ByteArrayComparable valueComparator = null;
  18.  try {
  19.   if (proto.getCompareFilter().hasComparator()) {
  20.    valueComparator = ProtobufUtil.toComparator(proto.getCompareFilter().getComparator());
  21.   }
  22.  } catch (IOException ioe) {
  23.   throw new DeserializationException(ioe);
  24.  }
  25.  return new RowFilter(valueCompareOp,valueComparator);
  26. }

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

  1. scan.setFilter(new RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(ROW1)));
  2. try (ResultScanner scanner = table.getScanner(scan)) {
  3.  resultCount = 0;
  4. scan.setFilter(new RowFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(ROW1)));
  5. try (ResultScanner scanner = table.getScanner(scan)) {
  6.  resultCount = 0;

内容来源于网络，如有侵权，请联系作者删除！

rowfilter

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com