Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/21118#discussion_r184216025
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala
---
@@ -86,7 +87,7 @@ class KafkaContinuousReader(
KafkaSourceOffset(JsonUtils.partitionOffsets(json))
}
- override def createUnsafeRowReaderFactories():
ju.List[DataReaderFactory[UnsafeRow]] = {
+ override def createReadTasks(): ju.List[ReadTask[InternalRow]] = {
--- End diff --
I've moved this to #21145. I'll rebase this PR on that one, so lets try to
get that in first.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
