File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed
sql/core/src/main/java/org/apache/spark/sql/sources/v2 Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -62,7 +62,7 @@ default String description() {
6262 /**
6363 * Returns the physical representation of this scan for batch query. By default this method throws
6464 * exception, data sources must overwrite this method to provide an implementation, if the
65- * {@link Table} that creates this scan returns {@link TableCapability#BATCH_READ} in its
65+ * {@link Table} that creates this scan returns {@link TableCapability#BATCH_READ} support in its
6666 * {@link Table#capabilities()}.
6767 *
6868 * @throws UnsupportedOperationException
Original file line number Diff line number Diff line change 1919
2020import org .apache .spark .annotation .Evolving ;
2121import org .apache .spark .sql .sources .v2 .Table ;
22+ import org .apache .spark .sql .sources .v2 .TableCapability ;
2223import org .apache .spark .sql .sources .v2 .writer .streaming .StreamingWrite ;
2324import org .apache .spark .sql .types .StructType ;
2425
@@ -57,8 +58,8 @@ default WriteBuilder withInputDataSchema(StructType schema) {
5758 /**
5859 * Returns a {@link BatchWrite} to write data to batch source. By default this method throws
5960 * exception, data sources must overwrite this method to provide an implementation, if the
60- * {@link Table} that creates this write returns BATCH_WRITE support in its
61- * {@link Table#capabilities()}.
61+ * {@link Table} that creates this write returns {@link TableCapability# BATCH_WRITE} support in
62+ * its {@link Table#capabilities()}.
6263 *
6364 * Note that, the returned {@link BatchWrite} can be null if the implementation supports SaveMode,
6465 * to indicate that no writing is needed. We can clean it up after removing
You can’t perform that action at this time.
0 commit comments