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