Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/22009#discussion_r208337008
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/sources/v2/ContinuousReadSupportProvider.java
---
@@ -39,7 +52,7 @@
* @param options the options for the returned data source reader, which
is an immutable
* case-insensitive string-to-string map.
*/
- ContinuousReader createContinuousReader(
+ ContinuousReadSupport createContinuousReadSupport(
Optional<StructType> schema,
--- End diff --
I though this was going to have two versions instead of passing the schema?
FYI @jose-torres
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
