You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2022/03/23 02:13:44 UTC
[spark] branch branch-3.3 updated: [MINOR] Add @since for DSv2 API
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 3a65ed9 [MINOR] Add @since for DSv2 API
3a65ed9 is described below
commit 3a65ed9b423ab9ac6e3e36be86daf128930f3ec9
Author: Cheng Pan <ch...@apache.org>
AuthorDate: Wed Mar 23 11:01:18 2022 +0900
[MINOR] Add @since for DSv2 API
### What changes were proposed in this pull request?
Add missing `since` for DSv2 API
### Why are the changes needed?
Let users know which version of the API was introduced.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
The change does not touch the code.
Closes #35935 from pan3793/minor.
Authored-by: Cheng Pan <ch...@apache.org>
Signed-off-by: Hyukjin Kwon <gu...@apache.org>
(cherry picked from commit f73d5289155a9fb9b81fe9b62324491bcf06a142)
Signed-off-by: Hyukjin Kwon <gu...@apache.org>
---
.../main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java | 1 +
.../spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java | 2 ++
2 files changed, 3 insertions(+)
diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java
index 777693938..a4421aa 100644
--- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java
+++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/HasPartitionKey.java
@@ -40,6 +40,7 @@ import org.apache.spark.sql.catalyst.InternalRow;
*
* @see org.apache.spark.sql.connector.read.SupportsReportPartitioning
* @see org.apache.spark.sql.connector.read.partitioning.Partitioning
+ * @since 3.3.0
*/
public interface HasPartitionKey extends InputPartition {
/**
diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java
index e8515c0..8e910b0 100644
--- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java
+++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/AcceptsLatestSeenOffset.java
@@ -25,6 +25,8 @@ package org.apache.spark.sql.connector.read.streaming;
* if the interface is implemented along with DSv1 streaming sources.
*
* The callback method will be called once per run.
+ *
+ * @since 3.3.0
*/
public interface AcceptsLatestSeenOffset extends SparkDataStream {
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org