Deprecate iceberg-pig (#11379)

apache · Oct 24, 2024 · fdc2c22 · fdc2c22
1 parent 12ac3ee
commit fdc2c22
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 1 deletion.
diff --git a/pig/src/main/java/org/apache/iceberg/pig/IcebergPigInputFormat.java b/pig/src/main/java/org/apache/iceberg/pig/IcebergPigInputFormat.java
@@ -56,6 +56,10 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+/**
+ * @deprecated will be removed in 1.8.0
+ */
+@Deprecated
 public class IcebergPigInputFormat<T> extends InputFormat<Void, T> {
   private static final Logger LOG = LoggerFactory.getLogger(IcebergPigInputFormat.class);
 
@@ -68,6 +72,7 @@ public class IcebergPigInputFormat<T> extends InputFormat<Void, T> {
   private List<InputSplit> splits;
 
   IcebergPigInputFormat(Table table, String signature) {
+    LOG.warn("Iceberg Pig is deprecated and will be removed in Iceberg 1.8.0");
     this.table = table;
     this.signature = signature;
   }

diff --git a/pig/src/main/java/org/apache/iceberg/pig/IcebergStorage.java b/pig/src/main/java/org/apache/iceberg/pig/IcebergStorage.java
@@ -64,6 +64,10 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+/**
+ * @deprecated will be removed in 1.8.0
+ */
+@Deprecated
 public class IcebergStorage extends LoadFunc
     implements LoadMetadata, LoadPredicatePushdown, LoadPushDown {
   private static final Logger LOG = LoggerFactory.getLogger(IcebergStorage.class);
@@ -77,6 +81,10 @@ public class IcebergStorage extends LoadFunc
 
   private IcebergRecordReader reader;
 
+  public IcebergStorage() {
+    LOG.warn("Iceberg Pig is deprecated and will be removed in Iceberg 1.8.0");
+  }
+
   @Override
   public void setLocation(String location, Job job) {
     LOG.info("[{}]: setLocation() -> {}", signature, location);

diff --git a/pig/src/main/java/org/apache/iceberg/pig/PigParquetReader.java b/pig/src/main/java/org/apache/iceberg/pig/PigParquetReader.java
@@ -60,9 +60,20 @@
 import org.apache.pig.data.DataByteArray;
 import org.apache.pig.data.Tuple;
 import org.apache.pig.data.TupleFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+/**
+ * @deprecated will be removed in 1.8.0
+ */
+@Deprecated
 public class PigParquetReader {
-  private PigParquetReader() {}
+
+  private static final Logger LOG = LoggerFactory.getLogger(PigParquetReader.class);
+
+  private PigParquetReader() {
+    LOG.warn("Iceberg Pig is deprecated and will be removed in Iceberg 1.8.0");
+  }
 
   @SuppressWarnings("unchecked")
   public static ParquetValueReader<Tuple> buildReader(

diff --git a/pig/src/main/java/org/apache/iceberg/pig/SchemaUtil.java b/pig/src/main/java/org/apache/iceberg/pig/SchemaUtil.java
@@ -29,6 +29,10 @@
 import org.apache.pig.data.DataType;
 import org.apache.pig.impl.logicalLayer.FrontendException;
 
+/**
+ * @deprecated will be removed in 1.8.0
+ */
+@Deprecated
 public class SchemaUtil {
 
   private SchemaUtil() {}