in modules/spark/src/main/java/org/apache/fluo/recipes/spark/FluoSparkHelper.java [174:188]
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);
}