Skip to content

Commit 9ff8ac7

Browse files
committed
javadoc fixes
1 parent 16e3c4a commit 9ff8ac7

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/BatchWrite.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public interface BatchWrite {
4646
* If this method fails (by throwing an exception), the action will fail and no Spark job will be
4747
* submitted.
4848
*
49-
* @param info Physical information about the input data that will be written to this data writer.
49+
* @param info Physical information about the input data that will be written to this table.
5050
*/
5151
DataWriterFactory createBatchWriterFactory(PhysicalWriteInfo info);
5252

sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/LogicalWriteInfo.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@
2727
@Evolving
2828
public interface LogicalWriteInfo {
2929
/**
30-
* @return `queryId` is a unique string of the query. It's possible that there are many queries
30+
* `queryId` is a unique string of the query. It's possible that there are many queries
3131
* running at the same time, or a query is restarted and resumed. {@link BatchWrite} can use
3232
* this id to identify the query.
3333
*/
3434
String queryId();
3535

3636
/**
37-
* @return the schema of the input data from Spark to data source.
37+
* the schema of the input data from Spark to data source.
3838
*/
3939
StructType schema();
4040
}

sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PhysicalWriteInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
@Evolving
2828
public interface PhysicalWriteInfo {
2929
/**
30-
* @return The number of partitions of the input data that is going to be written.
30+
* The number of partitions of the input data that is going to be written.
3131
*/
3232
int numPartitions();
3333
}

0 commit comments

Comments
 (0)