HADOOP_CONF_DIR
set in environmentSPARK_HOME
set in environmentThe CopyPlus5K example will create an Accumulo table called spark_example_input
and write 100 key/value entries into Accumulo with the values 0..99
. It then launches a Spark application that does following:
spark_example_input
table using AccumuloInputFormat
spark_example_output
) using one of two methods.AccumuloFileOutputFormat
and bulk import to Accumulo tableBatchWriter
in Spark code to write to the table.This application can be run using the command:
./run.sh batch /path/to/accumulo-client.properties
Change batch
to bulk
to use Bulk import method.