|
@@ -1,4 +1,4 @@
|
|
|
-package com.aliyun.odps.spark.examples
|
|
|
+package com.aliyun.odps.spark.examples.makedata
|
|
|
|
|
|
import org.apache.spark.sql.SparkSession
|
|
|
import com.aliyun.odps.TableSchema
|
|
@@ -10,7 +10,7 @@ import org.apache.hadoop.io.compress.GzipCodec
|
|
|
|
|
|
import scala.collection.JavaConversions._
|
|
|
|
|
|
-object makedata_01_readhdfs {
|
|
|
+object makedata_01_readtable2hdfs {
|
|
|
def main(args: Array[String]) {
|
|
|
val spark = SparkSession
|
|
|
.builder()
|