Examples of tableStats()

Examples of org.apache.blur.thrift.generated.Blur.Iface.tableStats()

30
31
32
33
34
35
36
37
38
  public static void main(String[] args) throws BlurException, TException, IOException {
    String connectionStr = args[0];
    final String tableName = args[1];

    Iface client = BlurClient.getClient(connectionStr);
    TableStats tableStats = client.tableStats(tableName);
    System.out.println(tableStats);
  }
}
View Full Code Here

Examples of org.apache.blur.thrift.generated.Blur.Iface.tableStats()

47
48
49
50
51
52
53
54
55
56
57
        tableInfo.put("cluster", cluster);
        tableInfo.put("name", table);
        tableInfo.put("enabled", descriptor.isEnabled());

        if (descriptor.isEnabled()) {
          TableStats stats = client.tableStats(table);
          tableInfo.put("rows", stats.getRowCount());
          tableInfo.put("records", stats.getRecordCount());

          Schema schema = client.schema(table);
          tableInfo.put("families", new ArrayList<String>(schema.getFamilies().keySet()));
View Full Code Here

Examples of org.apache.blur.thrift.generated.Blur.Iface.tableStats()

34
35
36
37
38
39
40
41
42
    // String uuid = UUID.randomUUID().toString();
    String uuid = "123456";
    Trace.setupTrace(uuid);
    System.out.println("Tracing on [" + uuid + "]");
    Iface client = BlurClient.getClient(connectionStr);
    System.out.println(client.tableStats(tableName));
    Trace.tearDownTrace();
  }
}
View Full Code Here

Examples of org.apache.blur.thrift.generated.Blur.Iface.tableStats()

170
171
172
173
174
175
176
177
178
179
180
    assertTrue(job.waitForCompletion(true));
    Counters ctrs = job.getCounters();
    System.out.println("Counters: " + ctrs);

    while (true) {
      TableStats tableStats = client.tableStats(tableName);
      System.out.println(tableStats);
      if (tableStats.getRowCount() > 0) {
        break;
      }
      Thread.sleep(5000);
View Full Code Here

Examples of org.apache.blur.thrift.generated.Blur.Iface.tableStats()

177
178
179
180
181
182
183
184
185
186
187
    assertTrue(job.waitForCompletion(true));
    Counters ctrs = job.getCounters();
    System.out.println("Counters: " + ctrs);

    while (true) {
      TableStats tableStats = client.tableStats(tableName);
      System.out.println(tableStats);
      if (tableStats.getRowCount() > 0) {
        break;
      }
      Thread.sleep(5000);
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.