Skip to content
Snippets Groups Projects
Commit 8e47ffe5 authored by dogfooter's avatar dogfooter
Browse files

add: signle local

parent 0c0cd066
No related branches found
No related tags found
No related merge requests found
......@@ -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)
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment