(iceberg) branch main updated: Deprecate iceberg-pig (#11379)

[dweeks]

This is an automated email from the ASF dual-hosted git repository.

dweeks pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new fdc2c223ef Deprecate iceberg-pig (#11379)
fdc2c223ef is described below

commit fdc2c223efa3367f8a10d9c49985326352b687b4
Author: JB Onofré <jbono...@apache.org>
AuthorDate: Thu Oct 24 20:55:18 2024 +0200

    Deprecate iceberg-pig (#11379)
---
 .../java/org/apache/iceberg/pig/IcebergPigInputFormat.java  |  5 +++++
 .../main/java/org/apache/iceberg/pig/IcebergStorage.java    |  8 ++++++++
 .../main/java/org/apache/iceberg/pig/PigParquetReader.java  | 13 ++++++++++++-
 pig/src/main/java/org/apache/iceberg/pig/SchemaUtil.java    |  4 ++++
 4 files changed, 29 insertions(+), 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
index 0d5a6dd927..932de72ac8 100644
--- 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.apache.pig.impl.util.ObjectSerializer;
 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
index 88233c58a3..0ce23c3991 100644
--- 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.apache.pig.impl.util.UDFContext;
 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
index 35b061db4f..15ba9068ca 100644
--- 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.DataBag;
 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
index e02cfaf677..4602a5effa 100644
--- 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.ResourceSchema.ResourceFieldSchema;
 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() {}