public void bulkImportRcvToAccumulo()

in modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java [174:188]

• 13 lines of code
• 1 McCabe index (conditional complexity)

  public void bulkImportRcvToAccumulo(JavaPairRDD<RowColumn, Bytes> data, String accumuloTable,
      BulkImportOptions opts) {

    data = partitionForAccumulo(data, accumuloTable, opts);

    JavaPairRDD<Key, Value> kvData = data.mapToPair(tuple -> {
      RowColumn rc = tuple._1();
      byte[] row = rc.getRow().toArray();
      byte[] cf = rc.getColumn().getFamily().toArray();
      byte[] cq = rc.getColumn().getQualifier().toArray();
      byte[] val = tuple._2().toArray();
      return new Tuple2<>(new Key(new Text(row), new Text(cf), new Text(cq), 0), new Value(val));
    });
    bulkImportKvToAccumulo(kvData, accumuloTable, opts);
  }