Examples of fetchColumn()

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

142
143
144
145
146
147
148
149
150
151
152
         
          Scanner scanner = connector.createScanner("test_ingest", labelAuths);
          scanner.setBatchSize(scanOpts.scanBatchSize);
          scanner.setRange(new Range(startKey, endKey));
          for (int j = 0; j < opts.cols; j++) {
            scanner.fetchColumn(new Text(opts.columnFamily), new Text("col_" + String.format("%07d", j)));
          }
         
          int recsReadBefore = recsRead;
         
          for (Entry<Key,Value> entry : scanner) {
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

592
593
594
595
596
597
598
599
600
601
602
     
      // setup a scanner within the bounds of this split
      for (Pair<Text,Text> c : getFetchedColumns(job)) {
        if (c.getSecond() != null) {
          log.debug("Fetching column " + c.getFirst() + ":" + c.getSecond());
          scanner.fetchColumn(c.getFirst(), c.getSecond());
        } else {
          log.debug("Fetching column family " + c.getFirst());
          scanner.fetchColumnFamily(c.getFirst());
        }
      }
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

61
62
63
64
65
66
67
68
69
70
71
    }
  }
 
  public void test() throws Exception {
    Scanner scanner = new MockInstance("counttest").getConnector("root", new PasswordToken("")).createScanner("dirlisttable", new Authorizations());
    scanner.fetchColumn(new Text("dir"), new Text("counts"));
    assertFalse(scanner.iterator().hasNext());
   
    Opts opts = new Opts();
    ScannerOpts scanOpts = new ScannerOpts();
    BatchWriterOpts bwOpts = new BatchWriterOpts();
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

609
610
611
612
613
614
615
616
617
618
619
     
      // setup a scanner within the bounds of this split
      for (Pair<Text,Text> c : getFetchedColumns(attempt)) {
        if (c.getSecond() != null) {
          log.debug("Fetching column " + c.getFirst() + ":" + c.getSecond());
          scanner.fetchColumn(c.getFirst(), c.getSecond());
        } else {
          log.debug("Fetching column family " + c.getFirst());
          scanner.fetchColumnFamily(c.getFirst());
        }
      }
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

53
54
55
56
57
58
59
60
61
62
63
    Connector conn = state.getConnector();
   
    Scanner imageScanner = conn.createScanner(imageTableName, new Authorizations());
   
    imageScanner.setRange(new Range(new Text(uuid), null));
    imageScanner.fetchColumn(Write.META_COLUMN_FAMILY, Write.SHA1_COLUMN_QUALIFIER);
   
    int minScan = Integer.parseInt(props.getProperty("minScan"));
    int maxScan = Integer.parseInt(props.getProperty("maxScan"));
   
    Random rand = new Random();
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

77
78
79
80
81
82
83
84
85
86
87
    Process hash = cluster.exec(RowHash.class, Collections.singletonList(hadoopTmpDirArg), "-i", c.getInstance().getInstanceName(), "-z", c.getInstance()
        .getZooKeepers(), "-u", "root", "-p", ROOT_PASSWORD, "-t", tablename, "--column", input_cfcq);
    assertEquals(0, hash.waitFor());

    Scanner s = c.createScanner(tablename, Authorizations.EMPTY);
    s.fetchColumn(new Text(input_cf), new Text(output_cq));
    int i = 0;
    for (Entry<Key,Value> entry : s) {
      MessageDigest md = MessageDigest.getInstance("MD5");
      byte[] check = Base64.encodeBase64(md.digest(("row" + i).getBytes()));
      assertEquals(entry.getValue().toString(), new String(check));
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

200
201
202
203
204
205
206
207
208
209
210
    conn.tableOperations().attachIterator("table1", is);
   
    Scanner scanner = conn.createScanner("table1", Authorizations.EMPTY);
    assertEquals(new HashSet<String>(Arrays.asList("2", "3")), getRows(scanner));

    scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
    assertEquals(new HashSet<String>(Arrays.asList("1", "3")), getRows(scanner));

    scanner.clearColumns();
    scanner.fetchColumn(new Text("cf1"), new Text("cq1"));
    assertEquals(new HashSet<String>(), getRows(scanner));
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

204
205
206
207
208
209
210
211
212
213
214
    scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
    assertEquals(new HashSet<String>(Arrays.asList("1", "3")), getRows(scanner));

    scanner.clearColumns();
    scanner.fetchColumn(new Text("cf1"), new Text("cq1"));
    assertEquals(new HashSet<String>(), getRows(scanner));

    scanner.setRange(new Range("0", "4"));
    scanner.clearColumns();
    assertEquals(new HashSet<String>(Arrays.asList("2", "3")), getRows(scanner));
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

221
222
223
224
225
226
227
228
229
230
231
    scanner.clearColumns();
    assertEquals(new HashSet<String>(), getRows(scanner));

    scanner.setRange(new Range("4"));
    scanner.clearColumns();
    scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
    scanner.fetchColumn(new Text("cf1"), new Text("cq4"));
    assertEquals(new HashSet<String>(Arrays.asList("4")), getRows(scanner));
   
  }
View Full Code Here

Examples of org.apache.accumulo.core.client.Scanner.fetchColumn()

222
223
224
225
226
227
228
229
230
231
232
    assertEquals(new HashSet<String>(), getRows(scanner));

    scanner.setRange(new Range("4"));
    scanner.clearColumns();
    scanner.fetchColumn(new Text("cf1"), new Text("cq2"));
    scanner.fetchColumn(new Text("cf1"), new Text("cq4"));
    assertEquals(new HashSet<String>(Arrays.asList("4")), getRows(scanner));
   
  }

  @Test
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.