[FLINK-28046][connectors] Mark SourceFunction interface as @deprecated

apache · Jun 30, 2023 · 07bf511 · 07bf511
1 parent 1ef9973
commit 07bf511
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ng-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/...ng-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
@@ -94,7 +94,11 @@
  * SourceContext#emitWatermark(Watermark)}.
  *
  * @param <T> The type of the elements produced by this source.
+ * @deprecated This interface will be removed in future versions. Use the new {@link
+ *     org.apache.flink.api.connector.source.Source} interface instead. NOTE: All sub-tasks from
+ *     FLINK-28045 must be closed before this API can be completely removed.
  */
+@Deprecated
 @Public
 public interface SourceFunction<T> extends Function, Serializable {