Package org.apache.accumulo.core.data

Examples of org.apache.accumulo.core.data.Column

1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
      for (List<Range> ranges : batch.values()) {
        mss.numRanges += ranges.size();
      }
     
      for (TColumn tcolumn : tcolumns)
        mss.columnSet.add(new Column(tcolumn));
     
      mss.threadPoolExtent = threadPoolExtent;
     
      long sid = sessionManager.createSession(mss, true);
     
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    Connector conn = HdfsZooInstance.getInstance().getConnector(credentials.user, credentials.password);
    Scanner scanner = conn.createScanner(t.toString(), auths);
    scanner.setBatchSize(20000);
    for (Entry<Key,Value> entry : scanner) {
      Key key = entry.getKey();
      Column column = new Column(TextUtil.getBytes(key.getColumnFamily()), TextUtil.getBytes(key.getColumnQualifier()), TextUtil.getBytes(key
          .getColumnVisibility()));
      result.add(new RowColumn(key.getRow(), column, key.getTimestamp()));
    }
    return result;
  }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
    this.extent = new KeyExtent(activeScan.extent);
   
    this.columns = new ArrayList<Column>(activeScan.columns.size());
   
    for (TColumn tcolumn : activeScan.columns)
      this.columns.add(new Column(tcolumn));
   
    this.ssiList = new ArrayList<String>();
    for (IterInfo ii : activeScan.ssiList) {
      this.ssiList.add(ii.iterName + "=" + ii.priority + "," + ii.className);
    }
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
  public void init(HashSet<Column> columns) {
    this.columnFamilies = new HashSet<ByteSequence>();
    this.columnsQualifiers = new HashMap<ByteSequence,HashSet<ByteSequence>>();
   
    for (Iterator<Column> iter = columns.iterator(); iter.hasNext();) {
      Column col = iter.next();
      if (col.columnQualifier != null) {
        ArrayByteSequence cq = new ArrayByteSequence(col.columnQualifier);
        HashSet<ByteSequence> cfset = this.columnsQualifiers.get(cq);
        if (cfset == null) {
          cfset = new HashSet<ByteSequence>();
View Full Code Here
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
  @Test
  public void test3() throws IOException {
    Value dv = new Value();
    TreeMap<Key,Value> tm = new TreeMap<Key,Value>();
    HashSet<Column> hsc = new HashSet<Column>();
    hsc.add(new Column("c".getBytes(), null, null));
   
    Text colf1 = new Text("a");
    Text colq1 = new Text("b");
    Text colf2 = new Text("c");
    Text colq2 = new Text("d");
    Text colf;
    Text colq;
    for (int i = 0; i < 1000; i++) {
      if (Math.abs(Math.ceil(i / 2.0) - i / 2.0) < .001) {
        colf = colf1;
        colq = colq1;
      } else {
        colf = colf2;
        colq = colq2;
      }
      Key k = new Key(new Text(String.format("%03d", i)), colf, colq);
      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);
   
View Full Code Here
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
    tm.put(new Key(new Text(String.format("%03d", 4)), new Text("b"), new Text("x")), dv);
    tm.put(new Key(new Text(String.format("%03d", 5)), new Text("b"), new Text("y")), dv);
   
    assertTrue(tm.size() == 5);
   
    int size = size(ncqf(tm, new Column("c".getBytes(), null, null)));
    assertTrue(size == 5);
   
    size = size(ncqf(tm, new Column("a".getBytes(), null, null)));
    assertTrue(size == 5);
   
    size = size(ncqf(tm, new Column("a".getBytes(), "x".getBytes(), null)));
    assertTrue(size == 1);
   
    size = size(ncqf(tm, new Column("a".getBytes(), "x".getBytes(), null), new Column("b".getBytes(), "x".getBytes(), null)));
    assertTrue(size == 2);
   
    size = size(ncqf(tm, new Column("a".getBytes(), "x".getBytes(), null), new Column("b".getBytes(), "y".getBytes(), null)));
    assertTrue(size == 2);
   
    size = size(ncqf(tm, new Column("a".getBytes(), "x".getBytes(), null), new Column("b".getBytes(), null, null)));
    assertTrue(size == 3);
  }
View Full Code Here
52
53
54
55
56
57
58
  public Text getColumnFamily() {
    return colf;
  }
 
  public Column toColumn() {
    return new Column(TextUtil.getBytes(colf), TextUtil.getBytes(colq), null);
  }
View Full Code Here
63
64
65
66
67
68
69
70
71
  MetadataLocationObtainer(Instance instance) {
   
    this.instance = instance;
   
    locCols = new TreeSet<Column>();
    locCols.add(new Column(TextUtil.getBytes(Constants.METADATA_CURRENT_LOCATION_COLUMN_FAMILY), null, null));
    locCols.add(Constants.METADATA_PREV_ROW_COLUMN.toColumn());
    columns = new ArrayList<Column>(locCols);
  }
View Full Code Here
128
129
130
131
132
133
134
135
   */
 
  @Override
  public synchronized void fetchColumnFamily(Text col) {
    ArgumentChecker.notNull(col);
    Column c = new Column(TextUtil.getBytes(col), null, null);
    fetchedColumns.add(c);
  }
View Full Code Here
135
136
137
138
139
140
141
142
  }
 
  @Override
  public synchronized void fetchColumn(Text colFam, Text colQual) {
    ArgumentChecker.notNull(colFam, colQual);
    Column c = new Column(TextUtil.getBytes(colFam), TextUtil.getBytes(colQual), null);
    fetchedColumns.add(c);
  }
View Full Code Here
TOP

Related Classes of org.apache.accumulo.core.data.Column

  • org.apache.accumulo.core.client.admin.ActiveScan
  • org.apache.accumulo.core.client.impl.ActiveScanImpl
  • org.apache.accumulo.core.client.impl.MetadataLocationObtainer
  • org.apache.accumulo.core.client.impl.ScannerOptions
  • org.apache.accumulo.core.client.impl.Translator$TColumnTranslator
  • org.apache.accumulo.core.client.mock.MockScannerBase
  • org.apache.accumulo.core.client.RangeTest
  • org.apache.accumulo.core.data.ColumnTest
  • org.apache.accumulo.core.data.RangeTest
  • org.apache.accumulo.core.data.thrift.TColumn
    • 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.