graph_sng_test.pig

/* This script (roughly) demonstrates the following:
 * 
 * 1. Load a file consisting of comma separated values for input data and graph names (/path/to/file,graphName)
 * 2. Insert all the information into Graphulo as a Single Table graph
 * 3. Load results from a single, hard-coded graph (SimpleSngInsertTestSingle) (Single is automatically added in Graphulo 1.0)
 * 4. Dump the first ten rows from the graph
 *
 */

REGISTER graphulo-pig.jar

-- Load file into Graphulo
A = LOAD 'insertSngInput.txt' USING PigStorage(',') AS (inputFile:chararray, graphName:chararray);
B = FOREACH A GENERATE edu.mit.ll.graphulo.pig.backend.InsertSingleTableGraph('config/localAccumulo.config',inputFile,graphName);

DUMP A;
DUMP B;

-- Read the graph from Graphulo using Accumulo default LOAD function
raw = LOAD 'accumulo://SimpleSngInsertTestSingle?instance=graphuloLocal&user=root&password=graphuloLocal&zookeepers=localhost'
      USING org.apache.pig.backend.hadoop.accumulo.AccumuloStorage('*', '') AS (row:chararray, columns:map[]);

raw = LIMIT raw 10;
DUMP raw;