Skip to content
Browse files

BlueprintsMapOutputReduce has been generalized to support arbitrary d…

…efinitions of uniqueness using Gremlin/Groovy distributed-cache style scripting. Bam.
  • Loading branch information...
1 parent 90c88bf commit 4726e73668191c118f726faca81c85d09f6a7106 @okram okram committed Jul 31, 2013
View
2 bin/titan-cassandra-output.properties
@@ -14,7 +14,7 @@ faunus.graph.output.titan.storage.batch-loading=true
# faunus.graph.output.titan.storage.cassandra.thrift.frame_size_mb=49
# faunus.graph.output.titan.storage.cassandra.thrift.max_message_size_mb=50
faunus.graph.output.titan.infer-schema=true
-# faunus.graph.output.blueprints.script-file=GetOrCreateVertex.groovy
+# faunus.graph.output.blueprints.script-file=BlueprintsScript.groovy
# controls size of transaction
mapred.max.split.size=5242880
mapred.job.reuse.jvm.num.tasks=-1
View
2 bin/titan-hbase-output.properties
@@ -12,7 +12,7 @@ faunus.graph.output.titan.storage.batch-loading=true
# faunus.graph.output.titan.ids.block-size=100000
# faunus.graph.output.titan.storage.idauthority-wait-time=1000
faunus.graph.output.titan.infer-schema=true
-# faunus.graph.output.blueprints.script-file=GetOrCreateVertex.groovy
+# faunus.graph.output.blueprints.script-file=BlueprintsScript.groovy
# controls size of transaction
mapred.max.split.size=5242880
mapred.job.reuse.jvm.num.tasks=-1
View
0 data/GetOrCreateVertex.groovy → data/BlueprintsScript.groovy
File renamed without changes.
View
4 src/test/java/com/thinkaurelius/faunus/formats/BlueprintsGraphOutputMapReduceTest.java
@@ -39,7 +39,7 @@ public void setUp() {
public void testTinkerGraphIncrementalLoading() throws Exception {
TinkerGraphOutputMapReduce.graph = new TinkerGraph();
Configuration conf = new Configuration();
- conf.set(BlueprintsGraphOutputMapReduce.FAUNUS_GRAPH_OUTPUT_BLUEPRINTS_SCRIPT_FILE, "./data/GetOrCreateVertex.groovy");
+ conf.set(BlueprintsGraphOutputMapReduce.FAUNUS_GRAPH_OUTPUT_BLUEPRINTS_SCRIPT_FILE, "./data/BlueprintsScript.groovy");
mapReduceDriver.withConfiguration(conf);
runWithGraph(generateGraph(BaseTest.ExampleGraph.TINKERGRAPH, conf), mapReduceDriver);
@@ -64,7 +64,7 @@ public void testTinkerGraphIncrementalLoading() throws Exception {
incrementalGraph.put(22l, stephen1);
incrementalGraph.put(33l, vadas1);
conf = new Configuration();
- conf.set(BlueprintsGraphOutputMapReduce.FAUNUS_GRAPH_OUTPUT_BLUEPRINTS_SCRIPT_FILE, "./data/GetOrCreateVertex.groovy");
+ conf.set(BlueprintsGraphOutputMapReduce.FAUNUS_GRAPH_OUTPUT_BLUEPRINTS_SCRIPT_FILE, "./data/BlueprintsScript.groovy");
setUp();

0 comments on commit 4726e73

Please sign in to comment.
Something went wrong with that request. Please try again.