Spark pipe 实例

package test import org.apache.spark.SparkConf import org.apache.spark.SparkContext object PipeTest { def main(args: Array[String]) { val sparkConf = new SparkConf().setAppName("pipe Test")
相关文章
相关标签/搜索