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 0d5a6dd9271f..932de72ac8c0 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.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * @deprecated will be removed in 1.8.0 + */ +@Deprecated public class IcebergPigInputFormat extends InputFormat { private static final Logger LOG = LoggerFactory.getLogger(IcebergPigInputFormat.class); @@ -68,6 +72,7 @@ public class IcebergPigInputFormat extends InputFormat { private List 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 88233c58a372..0ce23c39913a 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.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 35b061db4f9e..15ba9068caf5 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.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 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 e02cfaf677b8..4602a5effa97 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.data.DataType; import org.apache.pig.impl.logicalLayer.FrontendException; +/** + * @deprecated will be removed in 1.8.0 + */ +@Deprecated public class SchemaUtil { private SchemaUtil() {}