Github user anubhav100 commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1774#discussion_r161367434 --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDataFrameWriter.scala --- @@ -167,13 +167,20 @@ class CarbonDataFrameWriter(sqlContext: SQLContext, val dataFrame: DataFrame) { val carbonSchema = schema.map { field => s"${ field.name } ${ convertToCarbonType(field.dataType) }" } + val isStreaming = if (options.isStreaming) Some("true") else None + val property = Map( "SORT_COLUMNS" -> options.sortColumns, "DICTIONARY_INCLUDE" -> options.dictionaryInclude, "DICTIONARY_EXCLUDE" -> options.dictionaryExclude, - "TABLE_BLOCKSIZE" -> options.tableBlockSize - ).filter(_._2.isDefined).map(p => s"'${p._1}' = '${p._2.get}'").mkString(",") + "TABLE_BLOCKSIZE" -> options.tableBlockSize, + "STREAMING" -> isStreaming + ) + .filter(_._2.isDefined). --- End diff -- done and pushed
---