Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2366#discussion_r200321640
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/StreamHandoffRDD.scala
---
@@ -163,10 +164,13 @@ class StreamHandoffRDD[K, V](
val model = format.createQueryModel(inputSplit, attemptContext)
val inputFormat = new CarbonStreamInputFormat
val streamReader = inputFormat.createRecordReader(inputSplit,
attemptContext)
- .asInstanceOf[CarbonStreamRecordReader]
- streamReader.setVectorReader(false)
- streamReader.setQueryModel(model)
- streamReader.setUseRawRow(true)
+ .asInstanceOf[RecordReader[Void, Any]]
--- End diff --
Add these options to CreateRecordReader or to CarbonStreamInputFormat
---
