[TINKERPOP-320] BulkDumperVertexProgram

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0.2-incubating
• Fix Version/s: 3.1.1-incubating
• Component/s: process, structure
• Assignee: Daniel Kuppitz
• Reporter: Marko A. Rodriguez
• Created: 04/Nov/14 17:40
• Updated: 13/Jan/16 12:29
• Resolved: 13/Jan/16 12:29

Description

This is another trivial "bulker" that is vendor agnostic. For any Graph that provides a GraphComputer, BulkDumpingMapReduce is executed as such:

g.compute().mapReduce(BulkDumpingMapReduce.build().output('dir/').writer(GraphSONWriter.class).create()).submit()

The implementation is:

public BulkDumpingMapReduce implements MapReduce {
   public void map(vertex, emitter) {
     StringBufferThingy vertexString = new StringBufferThingy()  
     graphSONWriter.write(vertex,stringBufferStreamThingy);
     emitter.emit(vertexString.toString());
   }
}

NOTES:

• MapReduce generates a key/value pair result set. Thus, MapReduce.generateResult() would need to clip off the key and write the value to the output location.