nomoa · September 4, 2020 12:37
diff --git a/extract ntriple from rdd.scala b/extract ntriple from rdd.scala
  def getDirectoryWriter(outputPath: String, partitions: Int)(implicit spark: SparkSession): RDD[Row] => Unit = {
    rdd: RDD[Row] => {
      rdd
        .repartition(partitions)
        .map(r => s"${r.getAs("subject")} ${r.getAs("predicate")} ${r.getAs("object")} .")
        .saveAsTextFile(outputPath, classOf[BZip2Codec])
    }
  }
	def getDirectoryWriter(outputPath: String, partitions: Int)(implicit spark: SparkSession): RDD[Row] => Unit = {
	rdd: RDD[Row] => {
	rdd
	.repartition(partitions)
	.map(r => s"${r.getAs("subject")} ${r.getAs("predicate")} ${r.getAs("object")} .")
	.saveAsTextFile(outputPath, classOf[BZip2Codec])
	}
	}