Package org.apache.accumulo.core.iterators.system

Examples of org.apache.accumulo.core.iterators.system.ColumnQualifierFilter

68
69
70
71
72
73
74
75
76
77
78
  public void test3() {
    HashSet<Column> columns = new HashSet<Column>();
   
    columns.add(nc("cf2", "cq1"));
   
    ColumnQualifierFilter cf = new ColumnQualifierFilter(null, columns);
   
    assertFalse(cf.accept(nk("r1", "cf1", "cq1"), new Value(new byte[0])));
    assertTrue(cf.accept(nk("r1", "cf2", "cq1"), new Value(new byte[0])));
    assertFalse(cf.accept(nk("r1", "cf2", "cq2"), new Value(new byte[0])));
  }
View Full Code Here
2074
2075
2076
2077
2078
2079
2080
2081
2082
2083
2084
     
      TabletIteratorEnvironment iterEnv = new TabletIteratorEnvironment(IteratorScope.scan, acuTableConf, fileManager, files);
     
      DeletingIterator delIter = new DeletingIterator(multiIter, false);
     
      ColumnQualifierFilter colFilter = new ColumnQualifierFilter(delIter, options.columnSet);
     
      VisibilityFilter visFilter = new VisibilityFilter(colFilter, options.authorizations, options.defaultLabels);
     
      return iterEnv.getTopLevelIterator(IteratorUtil
          .loadIterators(IteratorScope.scan, visFilter, extent, acuTableConf, options.ssiList, options.ssio, iterEnv));
View Full Code Here
312
313
314
315
316
317
318
319
320
321
322
   
    DeletingIterator delIter = new DeletingIterator(multiIter, false);
   
    ColumnFamilySkippingIterator cfsi = new ColumnFamilySkippingIterator(delIter);
   
    ColumnQualifierFilter colFilter = new ColumnQualifierFilter(cfsi, new HashSet<Column>(options.fetchedColumns));
   
    byte[] defaultSecurityLabel;
   
    ColumnVisibility cv = new ColumnVisibility(acuTableConf.get(Property.TABLE_DEFAULT_SCANTIME_VISIBILITY));
    defaultSecurityLabel = cv.getExpression();
View Full Code Here
2079
2080
2081
2082
2083
2084
2085
2086
2087
2088
2089
     
      DeletingIterator delIter = new DeletingIterator(multiIter, false);
     
      ColumnFamilySkippingIterator cfsi = new ColumnFamilySkippingIterator(delIter);
     
      ColumnQualifierFilter colFilter = new ColumnQualifierFilter(cfsi, options.columnSet);
     
      VisibilityFilter visFilter = new VisibilityFilter(colFilter, options.authorizations, options.defaultLabels);
     
      return iterEnv.getTopLevelIterator(IteratorUtil
          .loadIterators(IteratorScope.scan, visFilter, extent, acuTableConf, options.ssiList, options.ssio, iterEnv));
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
      k.setTimestamp(157l);
      tm.put(k, dv);
    }
    assertTrue(tm.size() == 1000);
   
    ColumnQualifierFilter a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
    a.seek(new Range(), EMPTY_COL_FAMS, false);
    assertEquals(size(a), 1000);
   
    hsc = new HashSet<Column>();
    hsc.add(new Column("a".getBytes(), "b".getBytes(), null));
    a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
    a.seek(new Range(), EMPTY_COL_FAMS, false);
    int size = size(a);
    assertTrue("size was " + size, size == 500);
   
    hsc = new HashSet<Column>();
    a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
    a.seek(new Range(), EMPTY_COL_FAMS, false);
    size = size(a);
    assertTrue("size was " + size, size == 1000);
  }
View Full Code Here
316
317
318
319
320
321
322
323
324
   
    for (Column column : columns) {
      hsc.add(column);
    }
   
    ColumnQualifierFilter a = new ColumnQualifierFilter(new SortedMapIterator(tm), hsc);
    a.seek(new Range(), EMPTY_COL_FAMS, false);
    return a;
  }
View Full Code Here
TOP

Related Classes of org.apache.accumulo.core.iterators.system.ColumnQualifierFilter

  • org.apache.accumulo.core.client.impl.OfflineIterator
  • org.apache.accumulo.core.client.mock.MockScannerBase
  • org.apache.accumulo.core.data.ArrayByteSequence
  • org.apache.accumulo.core.data.Column
  • org.apache.accumulo.core.iterators.system.ColumnFilterTest
  • org.apache.accumulo.core.iterators.user.FilterTest
  • org.apache.accumulo.server.tabletserver.Tablet$ScanDataSource
  • org.apache.accumulo.server.test.performance.scan.CollectTabletStats
  • org.apache.accumulo.server.util.OfflineMetadataScanner
  • org.apache.accumulo.test.performance.scan.CollectTabletStats
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.