From 8e47ffe5ad9c8459a1294e9a2d664def12227f1d Mon Sep 17 00:00:00 2001
From: dogfooter <dogfooter219@gmail.com>
Date: Thu, 14 Jun 2018 04:25:20 +0900
Subject: [PATCH] add: signle local
---
.../scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala b/src/main/scala/com/dogfooter/rdfs/naive/NaiveRunningTask.scala
index 2eeae5a..8fc7de0 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)
}
}
--
GitLab