PARQUET-2355: Deprecate parquet-thrift

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/AbstractThriftWriteSupport.java

@@ -36,7 +36,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
+@Deprecated
 public abstract class AbstractThriftWriteSupport<T> extends WriteSupport<T> {
   public static final String PARQUET_THRIFT_CLASS = "parquet.thrift.class";
   private static final Logger LOG = LoggerFactory.getLogger(AbstractThriftWriteSupport.class);

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ParquetThriftBytesOutputFormat.java

@@ -32,6 +32,7 @@
 /**
  * Output format that turns Thrift bytes into Parquet format using the thrift TProtocol layer
  */
+@Deprecated
 public class ParquetThriftBytesOutputFormat extends ParquetOutputFormat<BytesWritable> {
 
   public static void setThriftClass(Job job, Class<? extends TBase<?, ?>> thriftClass) {

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ParquetThriftInputFormat.java

@@ -23,6 +23,7 @@
 
 import org.apache.parquet.hadoop.ParquetInputFormat;
 
+@Deprecated
 public class ParquetThriftInputFormat<T> extends ParquetInputFormat<T> {
 
   @SuppressWarnings("unchecked")

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ParquetThriftOutputFormat.java

@@ -26,6 +26,7 @@
 /**
  * @param <T> the thrift class use for serialization
  */
+@Deprecated
 public class ParquetThriftOutputFormat<T extends TBase<?,?>> extends ParquetOutputFormat<T> {
 
   public static void setThriftClass(Job job, Class<? extends TBase<?,?>> thriftClass) {

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/TBaseWriteSupport.java

@@ -23,6 +23,7 @@
 import org.apache.parquet.thrift.ThriftSchemaConverter;
 import org.apache.parquet.thrift.struct.ThriftType.StructType;
 
+@Deprecated
 public class TBaseWriteSupport<T extends TBase<?, ?>> extends AbstractThriftWriteSupport<T> {
 
   private static Configuration conf;

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ThriftBytesWriteSupport.java

@@ -48,6 +48,7 @@
 import org.apache.parquet.thrift.ThriftSchemaConverter;
 import org.apache.parquet.thrift.struct.ThriftType.StructType;
 
+@Deprecated
 public class ThriftBytesWriteSupport extends WriteSupport<BytesWritable> {
   private static final Logger LOG = LoggerFactory.getLogger(ThriftBytesWriteSupport.class);
   private static final String PARQUET_PROTOCOL_CLASS = "parquet.protocol.class";

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ThriftReadSupport.java

@@ -46,6 +46,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@Deprecated
 public class ThriftReadSupport<T> extends ReadSupport<T> {
   private static final Logger LOG = LoggerFactory.getLogger(ThriftReadSupport.class);
 

parquet-thrift/src/main/java/org/apache/parquet/hadoop/thrift/ThriftToParquetFileWriter.java

@@ -33,6 +33,7 @@
 /**
  * To create a Parquet file from the Thrift binary of records
  */
+@Deprecated
 public class ThriftToParquetFileWriter implements Closeable {
 
   private final RecordWriter<Void, BytesWritable> recordWriter;

parquet-thrift/src/main/java/org/apache/parquet/thrift/BufferedProtocolReadToWrite.java

@@ -52,6 +52,7 @@
  * be notified through {@link FieldIgnoredHandler#handleFieldIgnored(org.apache.thrift.protocol.TField)}
  * and {@link FieldIgnoredHandler#handleRecordHasFieldIgnored()}
  */
+@Deprecated
 public class BufferedProtocolReadToWrite implements ProtocolPipe {
 
   private interface Action {

parquet-thrift/src/main/java/org/apache/parquet/thrift/ConvertedField.java

@@ -32,6 +32,7 @@
  *
  * This interface is essentially a union of {keep, drop, sentinelUnion}
  */
+@Deprecated
 public interface ConvertedField {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/DecodingSchemaMismatchException.java

@@ -23,6 +23,7 @@
 /**
  * Throw this exception when the schema used for decoding is not compatible with the schema in the data.
  */
+@Deprecated
 public class DecodingSchemaMismatchException extends ParquetEncodingException {
   public DecodingSchemaMismatchException(String s) {
     super(s);

parquet-thrift/src/main/java/org/apache/parquet/thrift/FieldIgnoredHandler.java

@@ -23,6 +23,7 @@
 /**
  * Implements this class to handle when fields get ignored in {@link BufferedProtocolReadToWrite}
  */
+@Deprecated
 public abstract class FieldIgnoredHandler {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/KeepOnlyFirstPrimitiveFilter.java

@@ -26,6 +26,7 @@
  * A {@link FieldProjectionFilter} that keeps only the first primitive field
  * that it encounters.
  */
+@Deprecated
 class KeepOnlyFirstPrimitiveFilter implements FieldProjectionFilter {
   private boolean found = false;
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/ParquetProtocol.java

@@ -33,6 +33,7 @@
 /**
  * Allows simple implementation of partial protocols
  */
+@Deprecated
 public abstract class ParquetProtocol extends TProtocol {
 
   private String name;

parquet-thrift/src/main/java/org/apache/parquet/thrift/ParquetReadProtocol.java

@@ -36,6 +36,7 @@
 import org.slf4j.LoggerFactory;
 
 
+@Deprecated
 class ParquetReadProtocol extends ParquetProtocol {
   private static final Logger LOG = LoggerFactory.getLogger(ParquetReadProtocol.class);
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/ParquetWriteProtocol.java

@@ -50,6 +50,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@Deprecated
 public class ParquetWriteProtocol extends ParquetProtocol {
 
   public static final String WRITE_THREE_LEVEL_LISTS = "parquet.thrift.write-three-level-lists";

parquet-thrift/src/main/java/org/apache/parquet/thrift/ProtocolPipe.java

@@ -24,6 +24,7 @@
 /**
  * reads one record from an input and writes it to an output
  */
+@Deprecated
 public interface ProtocolPipe {
     void readOne(TProtocol in, TProtocol out) throws TException;
 }

parquet-thrift/src/main/java/org/apache/parquet/thrift/ProtocolReadToWrite.java

@@ -30,6 +30,7 @@
 /**
  * Class to read from one protocol and write to another one
  */
+@Deprecated
 public class ProtocolReadToWrite implements ProtocolPipe {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/SkippableException.java

@@ -25,6 +25,7 @@
  * Thrown when an error happened reading a thrift record
  * Ignoring this exception will skip the bad record
  */
+@Deprecated
 public class SkippableException extends ParquetRuntimeException {
   private static final long serialVersionUID = 1L;
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/TBaseRecordConverter.java

@@ -27,6 +27,7 @@
 import org.apache.parquet.schema.MessageType;
 import org.apache.parquet.thrift.struct.ThriftType.StructType;
 
+@Deprecated
 public class TBaseRecordConverter<T extends TBase<?,?>> extends ThriftRecordConverter<T> {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftMetaData.java

@@ -29,6 +29,7 @@
 /**
  * Metadata for thrift stored in the file footer
  */
+@Deprecated
 public class ThriftMetaData {
   private static final Logger LOG = LoggerFactory.getLogger(ThriftMetaData.class);
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftParquetReader.java

@@ -35,6 +35,7 @@
  * To read a parquet file into thrift objects
  * @param <T> the thrift type
  */
+@Deprecated
 public class ThriftParquetReader<T extends TBase<?,?>> extends ParquetReader<T> {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftParquetWriter.java

@@ -33,6 +33,7 @@
  *
  * @param <T> the type of the thrift class used to write data
  */
+@Deprecated
 public class ThriftParquetWriter<T extends TBase<?,?>> extends ParquetWriter<T> {
 
   public ThriftParquetWriter(Path file, Class<T> thriftClass, CompressionCodecName compressionCodecName) throws IOException {

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftReader.java

@@ -21,6 +21,7 @@
 import org.apache.thrift.TException;
 import org.apache.thrift.protocol.TProtocol;
 
+@Deprecated
 abstract public class ThriftReader<T> {
 
   public abstract T readOneRecord(TProtocol protocol) throws TException;

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftRecordConverter.java

@@ -63,6 +63,7 @@
  *
  * @param <T> the Java type of records created by this converter
  */
+@Deprecated
 public class ThriftRecordConverter<T> extends RecordMaterializer<T> {
 
   private static final Logger LOG = LoggerFactory.getLogger(ThriftRecordConverter.class);

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftSchemaConvertVisitor.java

@@ -71,6 +71,7 @@
  * Visitor Class for converting a thrift definition to parquet message type.
  * Projection can be done by providing a {@link FieldProjectionFilter}
  */
+@Deprecated
 class ThriftSchemaConvertVisitor implements ThriftType.StateVisitor<ConvertedField, ThriftSchemaConvertVisitor.State> {
   private final FieldProjectionFilter fieldProjectionFilter;
   private final boolean doProjection;

parquet-thrift/src/main/java/org/apache/parquet/thrift/ThriftSchemaConverter.java

@@ -49,6 +49,7 @@
  * Given a thrift class, this class converts it to parquet schema,
  * a {@link FieldProjectionFilter} can be specified for projection pushdown.
  */
+@Deprecated
 public class ThriftSchemaConverter {
   private final FieldProjectionFilter fieldProjectionFilter;
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/pig/ParquetThriftStorer.java

@@ -37,6 +37,7 @@
  * usage:
  * STORE 'foo' USING parquet.thrift.pig.ParquetThriftStorer('my.thrift.Class');
  */
+@Deprecated
 public class ParquetThriftStorer extends StoreFunc {
 
   private RecordWriter<Void, Tuple> recordWriter;

parquet-thrift/src/main/java/org/apache/parquet/thrift/pig/TupleToThriftWriteSupport.java

@@ -32,6 +32,7 @@
 /**
  * Stores Pig tuples as Thrift objects
  */
+@Deprecated
 public class TupleToThriftWriteSupport extends WriteSupport<Tuple> {
 
   private final String className;

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/FieldProjectionFilter.java

@@ -26,6 +26,7 @@
  * See {@link StrictFieldProjectionFilter} and
  * {@link org.apache.parquet.thrift.projection.deprecated.DeprecatedFieldProjectionFilter}
  */
+@Deprecated
 public interface FieldProjectionFilter {
 
   /**

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/FieldsPath.java

@@ -26,6 +26,7 @@
 /**
  * Represents an immutable column path as a sequence of fields.
  */
+@Deprecated
 public class FieldsPath {
   private final ArrayList<ThriftField> fields;
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/StrictFieldProjectionFilter.java

@@ -29,15 +29,13 @@
 /**
  * Stricter Implementation of {@link FieldProjectionFilter}.
  *
- * See {@link org.apache.parquet.thrift.projection.deprecated.DeprecatedFieldProjectionFilter} for the previous
- * syntax that allows for more powerful glob patterns, but has less error reporting and less strict requirements.
- *
  * This filter requires that every *possible* expansion of glob expressions (like '{x,y,z}') must match at least one
  * column. Each expansion may match more than one if it contains wildcards ('*').
  *
  * Note that this class is stateful -- it keeps track of which expanded glob paths have matched a column, so that it can
  * throw when {@link #assertNoUnmatchedPatterns()} is called.
  */
+@Deprecated
 public class StrictFieldProjectionFilter implements FieldProjectionFilter {
   private static final Logger LOG = LoggerFactory.getLogger(FieldProjectionFilter.class);
   private static final String GLOB_SEPARATOR = ";";

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/ThriftProjectionException.java

@@ -24,6 +24,7 @@
  * thrown if the schema can not be projected/filtered
  */
 
+@Deprecated
 public class ThriftProjectionException extends ParquetRuntimeException {
   private static final long serialVersionUID = 1L;
 

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/amend/DefaultEventsVisitor.java

@@ -34,6 +34,7 @@
 /**
  * Create a dummy events for all required fields according to thrift definition
  */
+@Deprecated
 class DefaultEventsVisitor implements ThriftType.StateVisitor<Void, Void> {
   List<ParquetProtocol> dummyEvents= new ArrayList<ParquetProtocol>();
   @Override

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/amend/DefaultProtocolEventsGenerator.java

@@ -33,6 +33,7 @@
  * when required fields are missing.
  * {@link ProtocolEventsAmender} will use this class to generate events for missing required fields
  */
+@Deprecated
 class DefaultProtocolEventsGenerator {
   public static ParquetProtocol READ_FIELD_STOP = new ParquetProtocol("readFieldBegin() => STOP") {
     final TField stop = new TField("", TType.STOP, (short) 0);

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/amend/ProtocolEventsAmender.java

@@ -29,6 +29,7 @@
 /**
  * fill in default value for required fields in TProtocols after projection is specified.
  */
+@Deprecated
 public class ProtocolEventsAmender {
   List<TProtocol> rootEvents;
   List<TProtocol> fixedEvents = new ArrayList<TProtocol>();

parquet-thrift/src/main/java/org/apache/parquet/thrift/projection/amend/ReadFieldBeginProtocol.java

@@ -24,6 +24,7 @@
 import org.apache.parquet.thrift.struct.ThriftField;
 import org.apache.parquet.thrift.struct.ThriftTypeID;
 
+@Deprecated
 public class ReadFieldBeginProtocol extends ParquetProtocol {
   private final ThriftField field;
   private final byte thriftType;