Github user rdblue commented on a diff in the pull request:
https://github.com/apache/spark/pull/22009#discussion_r208337291
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/sources/v2/MicroBatchReadSupportProvider.java
---
@@ -45,8 +51,8 @@
* @param options the options for the returned data source reader, which
is an immutable
* case-insensitive string-to-string map.
*/
- MicroBatchReader createMicroBatchReader(
- Optional<StructType> schema,
- String checkpointLocation,
- DataSourceOptions options);
+ MicroBatchReadSupport createMicroBatchReadSupport(
+ Optional<StructType> schema,
--- End diff --
Nit: whitespace change that doesn't fit with typical Java style of 2 indent
levels for method params.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
