From 89ec61c970c70e5104abb0d502d9bafe2ab23ef1 Mon Sep 17 00:00:00 2001 From: Bryan Keller Date: Thu, 21 Sep 2023 21:52:10 -0700 Subject: [PATCH] fix imports --- .../src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 2 +- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- .../src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 2 +- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- .../src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java | 2 +- .../main/java/org/apache/iceberg/flink/FlinkWriteOptions.java | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index 19c62404d717..ca7b1120bc81 100644 --- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -20,7 +20,7 @@ import java.time.Duration; import java.util.Map; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ReadableConfig; import org.apache.iceberg.DistributionMode; import org.apache.iceberg.FileFormat; diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index 97f722e0c5e6..df73f2e09cac 100644 --- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -19,7 +19,7 @@ package org.apache.iceberg.flink; import java.time.Duration; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOptions; import org.apache.iceberg.SnapshotRef; diff --git a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index 19c62404d717..ca7b1120bc81 100644 --- a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -20,7 +20,7 @@ import java.time.Duration; import java.util.Map; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ReadableConfig; import org.apache.iceberg.DistributionMode; import org.apache.iceberg.FileFormat; diff --git a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index 97f722e0c5e6..df73f2e09cac 100644 --- a/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -19,7 +19,7 @@ package org.apache.iceberg.flink; import java.time.Duration; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOptions; import org.apache.iceberg.SnapshotRef; diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java index 19c62404d717..ca7b1120bc81 100644 --- a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java +++ b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteConf.java @@ -20,7 +20,7 @@ import java.time.Duration; import java.util.Map; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ReadableConfig; import org.apache.iceberg.DistributionMode; import org.apache.iceberg.FileFormat; diff --git a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java index 97f722e0c5e6..df73f2e09cac 100644 --- a/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java +++ b/flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/FlinkWriteOptions.java @@ -19,7 +19,7 @@ package org.apache.iceberg.flink; import java.time.Duration; -import org.apache.calcite.linq4j.function.Experimental; +import org.apache.flink.annotation.Experimental; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigOptions; import org.apache.iceberg.SnapshotRef;