|
@@ -64,7 +64,6 @@ class CsvAdapter extends SparkConnect{
|
|
|
val df = sparkSession.read
|
|
val df = sparkSession.read
|
|
|
.option("header", "true")
|
|
.option("header", "true")
|
|
|
.option("inferSchema", "true")
|
|
.option("inferSchema", "true")
|
|
|
- .option("encoding","GBK")
|
|
|
|
|
.csv(csvHdfsLoc)
|
|
.csv(csvHdfsLoc)
|
|
|
.persist()
|
|
.persist()
|
|
|
|
|
|