org.apache.accumulo.core.client.Connector.createBatchWriter()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(102)

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

Connector.createBatchWriter介绍

[英]Factory method to create a BatchWriter connected to Accumulo.
[中]用于创建连接到Accumulo的BatchWriter的工厂方法。

代码示例

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void fillTable(Connector conn, String table) throws Exception {
  BatchWriter bw = conn.createBatchWriter(table, new BatchWriterConfig());
  for (String row : ROWS) {
   Mutation m = new Mutation(row);
   m.put("cf", "cq", "value");
   bw.addMutation(m);
  }
  bw.close();
 }
}

代码示例来源：origin: apache/incubator-rya

public static void writeMutations(final Connector connector, final String tableName, final Collection<Mutation> mutations) throws TableNotFoundException, MutationsRejectedException {
    final BatchWriter bw = connector.createBatchWriter(tableName, 10000l, 10000l, 4);
    for(final Mutation mutation : mutations) {
      bw.addMutation(mutation);
    }
    bw.flush();
    bw.close();
  }
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeSomeData(Connector conn, String table, int rows, int cols) throws Exception {
 BatchWriter bw = conn.createBatchWriter(table, new BatchWriterConfig());
 for (int row = 0; row < rows; row++) {
  Mutation m = new Mutation(Integer.toString(row));
  for (int col = 0; col < cols; col++) {
   String value = Integer.toString(col);
   m.put(value, "", value);
  }
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private static void update(Connector c, Mutation m)
  throws TableNotFoundException, MutationsRejectedException {
 BatchWriter bw = c.createBatchWriter(MetadataTable.NAME, new BatchWriterConfig());
 bw.addMutation(m);
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeFlush(Connector conn, String tablename, String row) throws Exception {
 BatchWriter bw = conn.createBatchWriter(tablename, new BatchWriterConfig());
 Mutation m = new Mutation(row);
 m.put("", "", "");
 bw.addMutation(m);
 bw.close();
 conn.tableOperations().flush(tablename, null, null, true);
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeFile(Connector conn, String tableName) throws Exception {
 BatchWriter bw = conn.createBatchWriter(tableName, new BatchWriterConfig());
 Mutation m = new Mutation("row");
 m.put("cf", "cq", "value");
 bw.addMutation(m);
 bw.close();
 conn.tableOperations().flush(tableName, null, null, true);
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeFlush(Connector conn, String tablename, String row) throws Exception {
  BatchWriter bw = conn.createBatchWriter(tablename, new BatchWriterConfig());
  Mutation m = new Mutation(row);
  m.put("", "", "");
  bw.addMutation(m);
  bw.close();
  conn.tableOperations().flush(tablename, null, null, true);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeData(Connector c, String table)
   throws TableNotFoundException, MutationsRejectedException {
  BatchWriter bw = c.createBatchWriter(table, new BatchWriterConfig());
  try {
   Random rand = new Random();
   for (int i = 0; i < 1000; i++) {
    Mutation m = new Mutation(String.format("%09x", rand.nextInt(100000 * 1000)));
    m.put("m", "order", "" + i);
    bw.addMutation(m);
   }
  } finally {
   bw.close();
  }
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

void writeRandomValue(Connector c, String tableName, int size) throws Exception {
 Random rand = new Random();
 byte data1[] = new byte[size];
 rand.nextBytes(data1);
 BatchWriter bw = c.createBatchWriter(tableName, new BatchWriterConfig());
 Mutation m1 = new Mutation("r" + rand.nextInt(909090));
 m1.put("data", "bl0b", new Value(data1));
 bw.addMutation(m1);
 bw.close();
 c.tableOperations().flush(tableName, null, null, true);
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void makeFile(Connector conn, String tablename) throws Exception {
 BatchWriter bw = conn.createBatchWriter(tablename, new BatchWriterConfig());
 byte[] empty = {};
 byte[] row = new byte[10];
 r.nextBytes(row);
 Mutation m = new Mutation(row, 0, 10);
 m.put(empty, empty, empty);
 bw.addMutation(m);
 bw.flush();
 bw.close();
 conn.tableOperations().flush(tablename, null, null, true);
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeSomeData(Connector conn, String table, int startRow, int rowCount, int startCol,
  int colCount) throws Exception {
 BatchWriterConfig config = new BatchWriterConfig();
 config.setMaxMemory(10 * 1024 * 1024);
 BatchWriter bw = conn.createBatchWriter(table, config);
 for (int r = startRow; r < startRow + rowCount; r++) {
  Mutation m = new Mutation(Integer.toHexString(r));
  for (int c = startCol; c < startCol + colCount; c++) {
   m.put("", Integer.toHexString(c), "");
  }
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeTestMutation(Connector userC)
  throws TableNotFoundException, MutationsRejectedException {
 BatchWriter batchWriter = userC.createBatchWriter(tableName, new BatchWriterConfig());
 Mutation m = new Mutation("1");
 m.put(new Text("2"), new Text("3"), new Value("".getBytes()));
 batchWriter.addMutation(m);
 batchWriter.flush();
 batchWriter.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeSome(String tableName, int n, BatchWriterConfig cfg) throws Exception {
 Connector c = getConnector();
 BatchWriter bw = c.createBatchWriter(tableName, cfg);
 for (int i = 0; i < n; i++) {
  Mutation m = new Mutation(i + "");
  m.put("", "", "");
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private BatchWriter writeData(String table1, Connector c)
  throws TableNotFoundException, MutationsRejectedException {
 BatchWriter bw = c.createBatchWriter(table1, new BatchWriterConfig());
 Mutation m1 = new Mutation("001");
 m1.put("data", "x", "9");
 m1.put("data", "y", "7");
 Mutation m2 = new Mutation("008");
 m2.put("data", "x", "3");
 m2.put("data", "y", "4");
 bw.addMutation(m1);
 bw.addMutation(m2);
 bw.flush();
 return bw;
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void insertData(String tableName, long ts) throws AccumuloException,
  AccumuloSecurityException, TableNotFoundException, MutationsRejectedException {
 BatchWriter bw = getConnector().createBatchWriter(tableName, null);
 for (int i = 0; i < 10000; i++) {
  String row = String.format("%09d", i);
  Mutation m = new Mutation(new Text(row));
  m.put(new Text("cf1"), new Text("cq1"), ts, new Value(Integer.toString(i).getBytes(UTF_8)));
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void insertData(String tableName, long ts)
  throws AccumuloException, AccumuloSecurityException, TableNotFoundException {
 BatchWriter bw = getConnector().createBatchWriter(tableName, null);
 for (int i = 0; i < 10000; i++) {
  String row = String.format("%09d", i);
  Mutation m = new Mutation(new Text(row));
  m.put(new Text("cf1"), new Text("cq1"), ts, new Value(("" + i).getBytes()));
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: NationalSecurityAgency/datawave

private String seedMetadataTable(Connector connector, long time, int keyVersionNum) throws TableNotFoundException, MutationsRejectedException {
  Value emptyVal = new Value();
  BatchWriter recordWriter = connector.createBatchWriter(metadataTableName, new BatchWriterConfig());
  
  SimpleDateFormat dateFormat = new SimpleDateFormat(DateNormalizer.ISO_8601_FORMAT_STRING);
  
  String normalizedVersionNum = NumericalEncoder.encode(Integer.toString(keyVersionNum));
  
  String dateString = dateFormat.format(new Date(time));
  String rowID = "edge_key";
  String columnFamily = "version";
  String columnQualifier = normalizedVersionNum + "/" + dateString;
  
  Mutation m = new Mutation(rowID);
  
  m.put(new Text(columnFamily), new Text(columnQualifier), emptyVal);
  
  recordWriter.addMutation(m);
  
  recordWriter.close();
  
  return dateString;
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void writeData(String tableName, Connector conn)
  throws AccumuloException, AccumuloSecurityException, TableExistsException,
  TableNotFoundException, MutationsRejectedException {
 TreeSet<Text> splits = new TreeSet<>();
 for (int i = 1; i < 100; i++) {
  splits.add(new Text(String.format("%06d", i * 100)));
 }
 conn.tableOperations().create(tableName);
 conn.tableOperations().addSplits(tableName, splits);
 BatchWriter bw = conn.createBatchWriter(tableName, new BatchWriterConfig());
 for (int i = 0; i < 100; i++) {
  String row = String.format("%06d", i * 100 + 3);
  Mutation m = new Mutation(row);
  m.put("cf1", "cq1", "1");
  bw.addMutation(m);
 }
 bw.close();
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

@Test
public void testRealWrite() throws Exception {
 Connector c = getConnector();
 c.tableOperations().create(TEST_TABLE);
 BatchWriter bw = c.createBatchWriter(TEST_TABLE, new BatchWriterConfig());
 Mutation m = new Mutation("Key");
 m.put("", "", "");
 bw.addMutation(m);
 bw.close();
 handleWriteTests(true);
}

代码示例来源：origin: org.apache.accumulo/accumulo-test

private void insertDefaultData(Connector c, String tableName) throws Exception {
 BatchWriter bw = c.createBatchWriter(tableName, new BatchWriterConfig());
 Mutation m1 = new Mutation(new Text("row1"));
 mput(m1, "cf1", "cq1", "BASE", "v1");
 mput(m1, "cf1", "cq2", "DEFLABEL", "v2");
 mput(m1, "cf1", "cq3", "", "v3");
 bw.addMutation(m1);
 bw.close();
}

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

Connector

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com