You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by op...@apache.org on 2022/04/08 02:29:03 UTC
[iceberg] branch master updated: Flink: Clear the deprecated FlinkSink#build. (#4524)
This is an automated email from the ASF dual-hosted git repository.
openinx pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new f7f392b48 Flink: Clear the deprecated FlinkSink#build. (#4524)
f7f392b48 is described below
commit f7f392b48dee695b5eeeb22f6dbc99b4a2565171
Author: openinx <op...@gmail.com>
AuthorDate: Fri Apr 8 10:28:56 2022 +0800
Flink: Clear the deprecated FlinkSink#build. (#4524)
---
.../main/java/org/apache/iceberg/flink/sink/FlinkSink.java | 12 ------------
.../main/java/org/apache/iceberg/flink/sink/FlinkSink.java | 12 ------------
.../main/java/org/apache/iceberg/flink/sink/FlinkSink.java | 12 ------------
3 files changed, 36 deletions(-)
diff --git a/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
index 5e8085d67..24e23941f 100644
--- a/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
+++ b/flink/v1.12/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
@@ -309,18 +309,6 @@ public class FlinkSink {
return appendDummySink(committerStream);
}
- /**
- * Append the iceberg sink operators to write records to iceberg table.
- *
- * @return {@link DataStreamSink} for sink.
- * @deprecated this will be removed in 0.14.0; use {@link #append()} because its returned {@link DataStreamSink}
- * has a more correct data type.
- */
- @Deprecated
- public DataStreamSink<RowData> build() {
- return chainIcebergOperators();
- }
-
/**
* Append the iceberg sink operators to write records to iceberg table.
*
diff --git a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
index 5e8085d67..24e23941f 100644
--- a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
+++ b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
@@ -309,18 +309,6 @@ public class FlinkSink {
return appendDummySink(committerStream);
}
- /**
- * Append the iceberg sink operators to write records to iceberg table.
- *
- * @return {@link DataStreamSink} for sink.
- * @deprecated this will be removed in 0.14.0; use {@link #append()} because its returned {@link DataStreamSink}
- * has a more correct data type.
- */
- @Deprecated
- public DataStreamSink<RowData> build() {
- return chainIcebergOperators();
- }
-
/**
* Append the iceberg sink operators to write records to iceberg table.
*
diff --git a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
index 407f3a499..72f0580cf 100644
--- a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
+++ b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
@@ -330,18 +330,6 @@ public class FlinkSink {
return appendDummySink(committerStream);
}
- /**
- * Append the iceberg sink operators to write records to iceberg table.
- *
- * @return {@link DataStreamSink} for sink.
- * @deprecated this will be removed in 0.14.0; use {@link #append()} because its returned {@link DataStreamSink}
- * has a more correct data type.
- */
- @Deprecated
- public DataStreamSink<RowData> build() {
- return chainIcebergOperators();
- }
-
/**
* Append the iceberg sink operators to write records to iceberg table.
*