Skip to content
Snippets Groups Projects
Commit 0e547063 authored by dogfooter's avatar dogfooter
Browse files

add: println

parent 386786fe
Branches
No related tags found
No related merge requests found
...@@ -65,7 +65,8 @@ class NaiveRunningTask { ...@@ -65,7 +65,8 @@ class NaiveRunningTask {
// //
PrintUtility.Print("Join Start" + System.currentTimeMillis()) println("helloa jaklsdfjaklsjflasjfioawjfio asj foijwaofij")
val RDD_JOIN_RULE_5 = Naive.rule5IndexA(RDD_ALPHA_SUB_PROPERTY_OF) val RDD_JOIN_RULE_5 = Naive.rule5IndexA(RDD_ALPHA_SUB_PROPERTY_OF)
val RDD_JOIN_RULE_11 = Naive.rule11IndexA(RDD_ALPHA_SUB_CLASS_OF) val RDD_JOIN_RULE_11 = Naive.rule11IndexA(RDD_ALPHA_SUB_CLASS_OF)
val RDD_JOIN_RULE_7 = Naive.rule7Index(RDD_JOIN_RULE_5, RDD_ALPHA_TRIPLE) val RDD_JOIN_RULE_7 = Naive.rule7Index(RDD_JOIN_RULE_5, RDD_ALPHA_TRIPLE)
...@@ -79,7 +80,7 @@ class NaiveRunningTask { ...@@ -79,7 +80,7 @@ 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( 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_JOIN_RULE_9)
PrintUtility.Print("Join Start" + System.currentTimeMillis()) println("helloa jaklsdfjaklsjflasjfioawjfio asj foijwaofij")
// RDD_ALL_JOINED.map(spo => spo.mkString("\t")).saveAsTextFile("/result/"+ now + instanceNum) // RDD_ALL_JOINED.map(spo => spo.mkString("\t")).saveAsTextFile("/result/"+ now + instanceNum)
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment