Description
use datafame to load data with tempCSV true(dataset.writer..format("carbondata").save), carbondata will generate sql to load data
the sql's configs only have SINGLE_PASS, other configs is invalid,such as QUOTECHAR.
the code is in CarbonDataFrameWriter:
private def makeLoadString(csvFolder: String, options: CarbonOption): String = {
val dbName = CarbonEnv.getDatabaseName(options.dbName)(sqlContext.sparkSession)
s"""
LOAD DATA INPATH '$csvFolder' |
INTO TABLE $dbName.${options.tableName} |
OPTIONS ('FILEHEADER' = '${dataFrame.columns.mkString(",")}', |
'SINGLE_PASS' = '${options.singlePass}') """.stripMargin } |
Attachments
Issue Links
- links to