diff --git a/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala b/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala index 2eeae5a6aa2b97d4100e4dca8a093f324f67ce73..8fc7de0365466e32bb35cb176bf3a2f7cbe24f5f 100644 --- a/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala +++ b/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala @@ -6,14 +6,14 @@ import org.apache.spark.SparkContext class NaiveRunningTask { // var inputFile = "" - var schemaFile = "file://home/dogfooter/local/source/input/schema/part-*" + var schemaFile = "file:///home/dogfooter/local/source/input/schema/part-*" var instanceFile = "" var instanceNum = "" def this(instanceFile: String) { this() - this.instanceFile = "file://home/dogfooter/local/source/input/instance/"+ instanceFile + "/part-*" + this.instanceFile = "file:///home/dogfooter/local/source/input/instance/"+ instanceFile + "/part-*" this.instanceNum = instanceFile } @@ -75,6 +75,6 @@ class NaiveRunningTask { val RDD_ALL_JOINED = RDD_JOIN_RULE_5.union(RDD_JOIN_RULE_11).union(RDD_JOIN_RULE_7).union(RDD_JOIN_RULE_2_3).union( RDD_JOIN_RULE_9) - RDD_ALL_JOINED.map(spo => spo.mkString("\t")).saveAsTextFile("file://home/dogfooter/local/result/RDFS-RULE-WHOLE/" + instanceNum) + RDD_ALL_JOINED.map(spo => spo.mkString("\t")).saveAsTextFile("file:///home/dogfooter/local/result/RDFS-RULE-WHOLE/" + instanceNum) } }