-
- Downloads
[SPARK-18530][SS][KAFKA] Change Kafka timestamp column type to TimestampType
## What changes were proposed in this pull request? Changed Kafka timestamp column type to TimestampType. ## How was this patch tested? `test("Kafka column types")`. Author: Shixiong Zhu <shixiong@databricks.com> Closes #15969 from zsxwing/SPARK-18530. (cherry picked from commit d0212eb0) Signed-off-by:Shixiong Zhu <shixiong@databricks.com>
Showing
- external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala 13 additions, 3 deletions...ain/scala/org/apache/spark/sql/kafka010/KafkaSource.scala
- external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala 80 additions, 1 deletion...cala/org/apache/spark/sql/kafka010/KafkaSourceSuite.scala
Loading
Please register or sign in to comment