You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@parquet.apache.org by bl...@apache.org on 2015/04/28 01:12:48 UTC
[51/51] [partial] parquet-mr git commit: PARQUET-23: Rename to
org.apache.parquet.
PARQUET-23: Rename to org.apache.parquet.
This includes all of the code updates by module (so that we can use github for the review). I think this is currently all of the changes needed.
Author: Ryan Blue <bl...@apache.org>
Closes #179 from rdblue/PARQUET-23-rename-to-org-apache and squashes the following commits:
5018c94 [Ryan Blue] PARQUET-23: Change artifacts to org.apache.parquet group id.
487b044 [Ryan Blue] PARQUET-23: POM fixes for move to org.apache.parquet.
fe76459 [Ryan Blue] PARQUET-23: Move parquet-tools to org.apache.parquet.
431bc6e [Ryan Blue] PARQUET-23: Move parquet-hive to org.apache.parquet.
382db6f [Ryan Blue] PARQUET-23: Move parquet-scrooge to org.apache.parquet.
f76b052 [Ryan Blue] PARQUET-23: Move parquet-scala to org.apache.parquet.
c557515 [Ryan Blue] PARQUET-23: Move parquet-protobuf to org.apache.parquet.
2a82366 [Ryan Blue] PARQUET-23: Move parquet-cascading to org.apache.parquet.
f33db35 [Ryan Blue] PARQUET-23: Move parquet-thrift to org.apache.parquet.
02399d2 [Ryan Blue] PARQUET-23: Move parquet-pig to org.apache.parquet.
e0bb9ad [Ryan Blue] PARQUET-23: Move parquet-benchmarks to org.apache.parquet.
55fb0c4 [Ryan Blue] PARQUET-23: Move parquet-avro to org.apache.parquet.
8b7318f [Ryan Blue] PARQUET-23: Move parquet-hadoop to org.apache.parquet.
666b3d7 [Ryan Blue] PARQUET-23: Move parquet-column to org.apache.parquet.
3aaf772 [Ryan Blue] PARQUET-23: Move parquet-encoding to org.apache.parquet.
9f6df3e [Ryan Blue] PARQUET-23: Move parquet-generator to org.apache.parquet.
e34edab [Ryan Blue] PARQUET-23: Move parquet-common to org.apache.parquet.
3ae3f7e [Ryan Blue] PARQUET-23: Use org.apache.parquet:parquet-format.
Project: http://git-wip-us.apache.org/repos/asf/parquet-mr/repo
Commit: http://git-wip-us.apache.org/repos/asf/parquet-mr/commit/b10870e4
Tree: http://git-wip-us.apache.org/repos/asf/parquet-mr/tree/b10870e4
Diff: http://git-wip-us.apache.org/repos/asf/parquet-mr/diff/b10870e4
Branch: refs/heads/master
Commit: b10870e4ee7d4168a7a1530494e0a8acd8e6cb3f
Parents: 720b988
Author: Ryan Blue <bl...@apache.org>
Authored: Mon Apr 27 16:11:42 2015 -0700
Committer: Ryan Blue <bl...@apache.org>
Committed: Mon Apr 27 16:11:42 2015 -0700
----------------------------------------------------------------------
parquet-avro/pom.xml | 10 +-
.../apache/parquet/avro/AvroDataSupplier.java | 31 +
.../avro/AvroIndexedRecordConverter.java | 700 ++++++++++++
.../parquet/avro/AvroParquetInputFormat.java | 84 ++
.../parquet/avro/AvroParquetOutputFormat.java | 50 +
.../apache/parquet/avro/AvroParquetReader.java | 70 ++
.../apache/parquet/avro/AvroParquetWriter.java | 106 ++
.../apache/parquet/avro/AvroReadSupport.java | 113 ++
.../parquet/avro/AvroRecordMaterializer.java | 46 +
.../parquet/avro/AvroSchemaConverter.java | 355 ++++++
.../apache/parquet/avro/AvroWriteSupport.java | 234 ++++
.../parquet/avro/SpecificDataSupplier.java | 29 +
.../org/apache/parquet/avro/package-info.java | 171 +++
.../java/parquet/avro/AvroDataSupplier.java | 31 -
.../avro/AvroIndexedRecordConverter.java | 700 ------------
.../parquet/avro/AvroParquetInputFormat.java | 84 --
.../parquet/avro/AvroParquetOutputFormat.java | 50 -
.../java/parquet/avro/AvroParquetReader.java | 70 --
.../java/parquet/avro/AvroParquetWriter.java | 106 --
.../main/java/parquet/avro/AvroReadSupport.java | 113 --
.../parquet/avro/AvroRecordMaterializer.java | 46 -
.../java/parquet/avro/AvroSchemaConverter.java | 355 ------
.../java/parquet/avro/AvroWriteSupport.java | 234 ----
.../java/parquet/avro/SpecificDataSupplier.java | 29 -
.../main/java/parquet/avro/package-info.java | 171 ---
.../org/apache/parquet/avro/AvroTestUtil.java | 69 ++
.../parquet/avro/TestArrayCompatibility.java | 999 +++++++++++++++++
.../parquet/avro/TestAvroDataSupplier.java | 43 +
.../parquet/avro/TestAvroSchemaConverter.java | 256 +++++
.../parquet/avro/TestBackwardCompatibility.java | 51 +
.../parquet/avro/TestInputOutputFormat.java | 144 +++
.../org/apache/parquet/avro/TestReadWrite.java | 460 ++++++++
.../avro/TestSpecificInputOutputFormat.java | 286 +++++
.../parquet/avro/TestSpecificReadWrite.java | 288 +++++
.../test/java/parquet/avro/AvroTestUtil.java | 69 --
.../parquet/avro/TestArrayCompatibility.java | 999 -----------------
.../java/parquet/avro/TestAvroDataSupplier.java | 43 -
.../parquet/avro/TestAvroSchemaConverter.java | 256 -----
.../parquet/avro/TestBackwardCompatibility.java | 51 -
.../parquet/avro/TestInputOutputFormat.java | 144 ---
.../test/java/parquet/avro/TestReadWrite.java | 460 --------
.../avro/TestSpecificInputOutputFormat.java | 286 -----
.../parquet/avro/TestSpecificReadWrite.java | 288 -----
parquet-avro/src/test/resources/all.avsc | 2 +-
.../src/test/resources/allFromParquet.avsc | 2 +-
parquet-avro/src/test/resources/car.avdl | 2 +-
parquet-benchmarks/pom.xml | 8 +-
.../parquet/benchmarks/BenchmarkConstants.java | 42 +
.../parquet/benchmarks/BenchmarkFiles.java | 40 +
.../parquet/benchmarks/BenchmarkUtils.java | 46 +
.../parquet/benchmarks/DataGenerator.java | 144 +++
.../parquet/benchmarks/ReadBenchmarks.java | 106 ++
.../parquet/benchmarks/WriteBenchmarks.java | 159 +++
.../parquet/benchmarks/BenchmarkConstants.java | 42 -
.../java/parquet/benchmarks/BenchmarkFiles.java | 40 -
.../java/parquet/benchmarks/BenchmarkUtils.java | 46 -
.../java/parquet/benchmarks/DataGenerator.java | 144 ---
.../java/parquet/benchmarks/ReadBenchmarks.java | 106 --
.../parquet/benchmarks/WriteBenchmarks.java | 159 ---
parquet-cascading/pom.xml | 10 +-
.../parquet/cascading/ParquetTBaseScheme.java | 80 ++
.../parquet/cascading/ParquetTupleScheme.java | 191 ++++
.../parquet/cascading/ParquetValueScheme.java | 162 +++
.../parquet/cascading/SchemaIntersection.java | 63 ++
.../parquet/cascading/TupleReadSupport.java | 80 ++
.../parquet/cascading/TupleWriteSupport.java | 106 ++
.../cascading/convert/TupleConverter.java | 115 ++
.../convert/TupleRecordMaterializer.java | 46 +
.../parquet/cascading/ParquetTBaseScheme.java | 80 --
.../parquet/cascading/ParquetTupleScheme.java | 191 ----
.../parquet/cascading/ParquetValueScheme.java | 162 ---
.../parquet/cascading/SchemaIntersection.java | 63 --
.../parquet/cascading/TupleReadSupport.java | 80 --
.../parquet/cascading/TupleWriteSupport.java | 106 --
.../cascading/convert/TupleConverter.java | 115 --
.../convert/TupleRecordMaterializer.java | 46 -
.../cascading/TestParquetTBaseScheme.java | 186 ++++
.../cascading/TestParquetTupleScheme.java | 182 +++
.../cascading/TestParquetTBaseScheme.java | 186 ----
.../cascading/TestParquetTupleScheme.java | 182 ---
parquet-cascading/src/test/thrift/test.thrift | 2 +-
parquet-column/pom.xml | 12 +-
.../apache/parquet/column/ColumnDescriptor.java | 129 +++
.../apache/parquet/column/ColumnReadStore.java | 34 +
.../org/apache/parquet/column/ColumnReader.java | 115 ++
.../apache/parquet/column/ColumnWriteStore.java | 61 ++
.../org/apache/parquet/column/ColumnWriter.java | 87 ++
.../org/apache/parquet/column/Dictionary.java | 66 ++
.../org/apache/parquet/column/Encoding.java | 291 +++++
.../parquet/column/ParquetProperties.java | 242 ++++
.../parquet/column/UnknownColumnException.java | 42 +
.../column/UnknownColumnTypeException.java | 43 +
.../org/apache/parquet/column/ValuesType.java | 29 +
.../column/impl/ColumnReadStoreImpl.java | 82 ++
.../parquet/column/impl/ColumnReaderImpl.java | 661 +++++++++++
.../parquet/column/impl/ColumnWriteStoreV1.java | 135 +++
.../parquet/column/impl/ColumnWriteStoreV2.java | 166 +++
.../parquet/column/impl/ColumnWriterV1.java | 278 +++++
.../parquet/column/impl/ColumnWriterV2.java | 304 +++++
.../apache/parquet/column/page/DataPage.java | 53 +
.../apache/parquet/column/page/DataPageV1.java | 98 ++
.../apache/parquet/column/page/DataPageV2.java | 156 +++
.../parquet/column/page/DictionaryPage.java | 88 ++
.../org/apache/parquet/column/page/Page.java | 49 +
.../parquet/column/page/PageReadStore.java | 46 +
.../apache/parquet/column/page/PageReader.java | 43 +
.../parquet/column/page/PageWriteStore.java | 38 +
.../apache/parquet/column/page/PageWriter.java | 89 ++
.../column/statistics/BinaryStatistics.java | 108 ++
.../column/statistics/BooleanStatistics.java | 108 ++
.../column/statistics/DoubleStatistics.java | 108 ++
.../column/statistics/FloatStatistics.java | 108 ++
.../column/statistics/IntStatistics.java | 108 ++
.../column/statistics/LongStatistics.java | 108 ++
.../parquet/column/statistics/Statistics.java | 247 +++++
.../statistics/StatisticsClassException.java | 34 +
.../parquet/column/values/RequiresFallback.java | 54 +
.../parquet/column/values/ValuesReader.java | 126 +++
.../parquet/column/values/ValuesWriter.java | 128 +++
.../bitpacking/BitPackingValuesReader.java | 91 ++
.../bitpacking/BitPackingValuesWriter.java | 125 +++
.../bitpacking/ByteBitPackingValuesReader.java | 83 ++
.../bitpacking/ByteBitPackingValuesWriter.java | 86 ++
.../column/values/boundedint/BitReader.java | 123 +++
.../column/values/boundedint/BitWriter.java | 159 +++
.../boundedint/BoundedIntValuesFactory.java | 32 +
.../boundedint/BoundedIntValuesReader.java | 93 ++
.../boundedint/BoundedIntValuesWriter.java | 159 +++
.../values/boundedint/DevNullValuesWriter.java | 89 ++
.../boundedint/ZeroIntegerValuesReader.java | 52 +
.../values/delta/DeltaBinaryPackingConfig.java | 57 +
.../delta/DeltaBinaryPackingValuesReader.java | 170 +++
.../delta/DeltaBinaryPackingValuesWriter.java | 269 +++++
.../DeltaLengthByteArrayValuesReader.java | 70 ++
.../DeltaLengthByteArrayValuesWriter.java | 106 ++
.../deltastrings/DeltaByteArrayReader.java | 78 ++
.../deltastrings/DeltaByteArrayWriter.java | 92 ++
.../dictionary/DictionaryValuesReader.java | 135 +++
.../dictionary/DictionaryValuesWriter.java | 625 +++++++++++
.../column/values/dictionary/IntList.java | 123 +++
.../dictionary/PlainValuesDictionary.java | 310 ++++++
.../values/fallback/FallbackValuesWriter.java | 190 ++++
.../values/plain/BinaryPlainValuesReader.java | 70 ++
.../values/plain/BooleanPlainValuesReader.java | 75 ++
.../values/plain/BooleanPlainValuesWriter.java | 78 ++
.../FixedLenByteArrayPlainValuesReader.java | 67 ++
.../FixedLenByteArrayPlainValuesWriter.java | 98 ++
.../column/values/plain/PlainValuesReader.java | 135 +++
.../column/values/plain/PlainValuesWriter.java | 143 +++
.../rle/RunLengthBitPackingHybridDecoder.java | 109 ++
.../rle/RunLengthBitPackingHybridEncoder.java | 291 +++++
.../RunLengthBitPackingHybridValuesReader.java | 77 ++
.../RunLengthBitPackingHybridValuesWriter.java | 88 ++
.../parquet/example/DummyRecordConverter.java | 114 ++
.../java/org/apache/parquet/example/Paper.java | 167 +++
.../org/apache/parquet/example/data/Group.java | 143 +++
.../parquet/example/data/GroupFactory.java | 25 +
.../parquet/example/data/GroupValueSource.java | 89 ++
.../parquet/example/data/GroupWriter.java | 62 ++
.../example/data/simple/BinaryValue.java | 52 +
.../example/data/simple/BooleanValue.java | 44 +
.../example/data/simple/DoubleValue.java | 45 +
.../parquet/example/data/simple/FloatValue.java | 45 +
.../parquet/example/data/simple/Int96Value.java | 46 +
.../example/data/simple/IntegerValue.java | 46 +
.../parquet/example/data/simple/LongValue.java | 45 +
.../parquet/example/data/simple/NanoTime.java | 80 ++
.../parquet/example/data/simple/Primitive.java | 60 +
.../example/data/simple/SimpleGroup.java | 232 ++++
.../example/data/simple/SimpleGroupFactory.java | 38 +
.../simple/convert/GroupRecordConverter.java | 57 +
.../simple/convert/SimpleGroupConverter.java | 67 ++
.../convert/SimplePrimitiveConverter.java | 88 ++
.../apache/parquet/filter/AndRecordFilter.java | 64 ++
.../apache/parquet/filter/ColumnPredicates.java | 190 ++++
.../parquet/filter/ColumnRecordFilter.java | 75 ++
.../apache/parquet/filter/NotRecordFilter.java | 58 +
.../apache/parquet/filter/OrRecordFilter.java | 62 ++
.../parquet/filter/PagedRecordFilter.java | 64 ++
.../org/apache/parquet/filter/RecordFilter.java | 34 +
.../parquet/filter/UnboundRecordFilter.java | 36 +
.../parquet/filter2/compat/FilterCompat.java | 158 +++
.../parquet/filter2/predicate/FilterApi.java | 212 ++++
.../filter2/predicate/FilterPredicate.java | 72 ++
.../predicate/LogicalInverseRewriter.java | 113 ++
.../filter2/predicate/LogicalInverter.java | 108 ++
.../parquet/filter2/predicate/Operators.java | 526 +++++++++
.../predicate/SchemaCompatibilityValidator.java | 193 ++++
.../parquet/filter2/predicate/Statistics.java | 42 +
.../filter2/predicate/UserDefinedPredicate.java | 108 ++
.../parquet/filter2/predicate/ValidTypeMap.java | 178 +++
.../recordlevel/FilteringGroupConverter.java | 115 ++
.../FilteringPrimitiveConverter.java | 109 ++
.../FilteringRecordMaterializer.java | 115 ++
.../IncrementallyUpdatedFilterPredicate.java | 157 +++
...ntallyUpdatedFilterPredicateBuilderBase.java | 97 ++
...mentallyUpdatedFilterPredicateEvaluator.java | 63 ++
...ementallyUpdatedFilterPredicateResetter.java | 60 +
.../org/apache/parquet/io/BaseRecordReader.java | 144 +++
.../java/org/apache/parquet/io/ColumnIO.java | 138 +++
.../org/apache/parquet/io/ColumnIOFactory.java | 161 +++
.../apache/parquet/io/CompilationException.java | 47 +
.../apache/parquet/io/EmptyRecordReader.java | 50 +
.../apache/parquet/io/FilteredRecordReader.java | 99 ++
.../org/apache/parquet/io/GroupColumnIO.java | 122 +++
.../parquet/io/InvalidRecordException.java | 48 +
.../org/apache/parquet/io/MessageColumnIO.java | 396 +++++++
.../parquet/io/ParquetDecodingException.java | 47 +
.../parquet/io/ParquetEncodingException.java | 47 +
.../apache/parquet/io/PrimitiveColumnIO.java | 113 ++
.../io/RecordConsumerLoggingWrapper.java | 178 +++
.../org/apache/parquet/io/RecordReader.java | 43 +
.../parquet/io/RecordReaderImplementation.java | 473 ++++++++
.../parquet/io/ValidatingRecordConsumer.java | 230 ++++
.../java/org/apache/parquet/io/api/Binary.java | 413 +++++++
.../org/apache/parquet/io/api/Converter.java | 40 +
.../apache/parquet/io/api/GroupConverter.java | 58 +
.../parquet/io/api/PrimitiveConverter.java | 111 ++
.../apache/parquet/io/api/RecordConsumer.java | 128 +++
.../parquet/io/api/RecordMaterializer.java | 48 +
.../parquet/schema/ConversionPatterns.java | 104 ++
.../apache/parquet/schema/DecimalMetadata.java | 57 +
.../org/apache/parquet/schema/GroupType.java | 391 +++++++
...IncompatibleSchemaModificationException.java | 49 +
.../org/apache/parquet/schema/MessageType.java | 148 +++
.../parquet/schema/MessageTypeParser.java | 216 ++++
.../org/apache/parquet/schema/OriginalType.java | 42 +
.../apache/parquet/schema/PrimitiveType.java | 530 +++++++++
.../java/org/apache/parquet/schema/Type.java | 317 ++++++
.../apache/parquet/schema/TypeConverter.java | 55 +
.../org/apache/parquet/schema/TypeVisitor.java | 46 +
.../java/org/apache/parquet/schema/Types.java | 668 +++++++++++
.../java/parquet/column/ColumnDescriptor.java | 129 ---
.../java/parquet/column/ColumnReadStore.java | 34 -
.../main/java/parquet/column/ColumnReader.java | 115 --
.../java/parquet/column/ColumnWriteStore.java | 61 --
.../main/java/parquet/column/ColumnWriter.java | 87 --
.../main/java/parquet/column/Dictionary.java | 66 --
.../src/main/java/parquet/column/Encoding.java | 291 -----
.../java/parquet/column/ParquetProperties.java | 242 ----
.../parquet/column/UnknownColumnException.java | 42 -
.../column/UnknownColumnTypeException.java | 43 -
.../main/java/parquet/column/ValuesType.java | 29 -
.../column/impl/ColumnReadStoreImpl.java | 82 --
.../parquet/column/impl/ColumnReaderImpl.java | 661 -----------
.../parquet/column/impl/ColumnWriteStoreV1.java | 135 ---
.../parquet/column/impl/ColumnWriteStoreV2.java | 166 ---
.../parquet/column/impl/ColumnWriterV1.java | 279 -----
.../parquet/column/impl/ColumnWriterV2.java | 305 ------
.../main/java/parquet/column/page/DataPage.java | 53 -
.../java/parquet/column/page/DataPageV1.java | 98 --
.../java/parquet/column/page/DataPageV2.java | 156 ---
.../parquet/column/page/DictionaryPage.java | 88 --
.../src/main/java/parquet/column/page/Page.java | 49 -
.../java/parquet/column/page/PageReadStore.java | 46 -
.../java/parquet/column/page/PageReader.java | 43 -
.../parquet/column/page/PageWriteStore.java | 38 -
.../java/parquet/column/page/PageWriter.java | 89 --
.../column/statistics/BinaryStatistics.java | 108 --
.../column/statistics/BooleanStatistics.java | 108 --
.../column/statistics/DoubleStatistics.java | 108 --
.../column/statistics/FloatStatistics.java | 108 --
.../column/statistics/IntStatistics.java | 108 --
.../column/statistics/LongStatistics.java | 108 --
.../parquet/column/statistics/Statistics.java | 247 -----
.../statistics/StatisticsClassException.java | 34 -
.../parquet/column/values/RequiresFallback.java | 54 -
.../parquet/column/values/ValuesReader.java | 126 ---
.../parquet/column/values/ValuesWriter.java | 128 ---
.../bitpacking/BitPackingValuesReader.java | 91 --
.../bitpacking/BitPackingValuesWriter.java | 125 ---
.../bitpacking/ByteBitPackingValuesReader.java | 83 --
.../bitpacking/ByteBitPackingValuesWriter.java | 86 --
.../column/values/boundedint/BitReader.java | 123 ---
.../column/values/boundedint/BitWriter.java | 159 ---
.../boundedint/BoundedIntValuesFactory.java | 32 -
.../boundedint/BoundedIntValuesReader.java | 93 --
.../boundedint/BoundedIntValuesWriter.java | 159 ---
.../values/boundedint/DevNullValuesWriter.java | 89 --
.../boundedint/ZeroIntegerValuesReader.java | 52 -
.../values/delta/DeltaBinaryPackingConfig.java | 57 -
.../delta/DeltaBinaryPackingValuesReader.java | 170 ---
.../delta/DeltaBinaryPackingValuesWriter.java | 269 -----
.../DeltaLengthByteArrayValuesReader.java | 70 --
.../DeltaLengthByteArrayValuesWriter.java | 106 --
.../deltastrings/DeltaByteArrayReader.java | 78 --
.../deltastrings/DeltaByteArrayWriter.java | 92 --
.../dictionary/DictionaryValuesReader.java | 135 ---
.../dictionary/DictionaryValuesWriter.java | 625 -----------
.../column/values/dictionary/IntList.java | 123 ---
.../dictionary/PlainValuesDictionary.java | 310 ------
.../values/fallback/FallbackValuesWriter.java | 190 ----
.../values/plain/BinaryPlainValuesReader.java | 70 --
.../values/plain/BooleanPlainValuesReader.java | 75 --
.../values/plain/BooleanPlainValuesWriter.java | 78 --
.../FixedLenByteArrayPlainValuesReader.java | 67 --
.../FixedLenByteArrayPlainValuesWriter.java | 98 --
.../column/values/plain/PlainValuesReader.java | 135 ---
.../column/values/plain/PlainValuesWriter.java | 143 ---
.../rle/RunLengthBitPackingHybridDecoder.java | 109 --
.../rle/RunLengthBitPackingHybridEncoder.java | 291 -----
.../RunLengthBitPackingHybridValuesReader.java | 77 --
.../RunLengthBitPackingHybridValuesWriter.java | 88 --
.../parquet/example/DummyRecordConverter.java | 114 --
.../src/main/java/parquet/example/Paper.java | 167 ---
.../main/java/parquet/example/data/Group.java | 143 ---
.../java/parquet/example/data/GroupFactory.java | 25 -
.../parquet/example/data/GroupValueSource.java | 89 --
.../java/parquet/example/data/GroupWriter.java | 62 --
.../example/data/simple/BinaryValue.java | 52 -
.../example/data/simple/BooleanValue.java | 44 -
.../example/data/simple/DoubleValue.java | 45 -
.../parquet/example/data/simple/FloatValue.java | 45 -
.../parquet/example/data/simple/Int96Value.java | 46 -
.../example/data/simple/IntegerValue.java | 46 -
.../parquet/example/data/simple/LongValue.java | 45 -
.../parquet/example/data/simple/NanoTime.java | 80 --
.../parquet/example/data/simple/Primitive.java | 60 -
.../example/data/simple/SimpleGroup.java | 232 ----
.../example/data/simple/SimpleGroupFactory.java | 38 -
.../simple/convert/GroupRecordConverter.java | 57 -
.../simple/convert/SimpleGroupConverter.java | 67 --
.../convert/SimplePrimitiveConverter.java | 88 --
.../java/parquet/filter/AndRecordFilter.java | 64 --
.../java/parquet/filter/ColumnPredicates.java | 190 ----
.../java/parquet/filter/ColumnRecordFilter.java | 75 --
.../java/parquet/filter/NotRecordFilter.java | 58 -
.../java/parquet/filter/OrRecordFilter.java | 62 --
.../java/parquet/filter/PagedRecordFilter.java | 64 --
.../main/java/parquet/filter/RecordFilter.java | 34 -
.../parquet/filter/UnboundRecordFilter.java | 36 -
.../parquet/filter2/compat/FilterCompat.java | 158 ---
.../parquet/filter2/predicate/FilterApi.java | 212 ----
.../filter2/predicate/FilterPredicate.java | 72 --
.../predicate/LogicalInverseRewriter.java | 113 --
.../filter2/predicate/LogicalInverter.java | 108 --
.../parquet/filter2/predicate/Operators.java | 526 ---------
.../predicate/SchemaCompatibilityValidator.java | 193 ----
.../parquet/filter2/predicate/Statistics.java | 42 -
.../filter2/predicate/UserDefinedPredicate.java | 108 --
.../parquet/filter2/predicate/ValidTypeMap.java | 178 ---
.../recordlevel/FilteringGroupConverter.java | 115 --
.../FilteringPrimitiveConverter.java | 109 --
.../FilteringRecordMaterializer.java | 115 --
.../IncrementallyUpdatedFilterPredicate.java | 157 ---
...ntallyUpdatedFilterPredicateBuilderBase.java | 97 --
...mentallyUpdatedFilterPredicateEvaluator.java | 63 --
...ementallyUpdatedFilterPredicateResetter.java | 60 -
.../main/java/parquet/io/BaseRecordReader.java | 144 ---
.../src/main/java/parquet/io/ColumnIO.java | 138 ---
.../main/java/parquet/io/ColumnIOFactory.java | 163 ---
.../java/parquet/io/CompilationException.java | 47 -
.../main/java/parquet/io/EmptyRecordReader.java | 50 -
.../java/parquet/io/FilteredRecordReader.java | 99 --
.../src/main/java/parquet/io/GroupColumnIO.java | 122 ---
.../java/parquet/io/InvalidRecordException.java | 48 -
.../main/java/parquet/io/MessageColumnIO.java | 396 -------
.../parquet/io/ParquetDecodingException.java | 47 -
.../parquet/io/ParquetEncodingException.java | 47 -
.../main/java/parquet/io/PrimitiveColumnIO.java | 113 --
.../io/RecordConsumerLoggingWrapper.java | 178 ---
.../src/main/java/parquet/io/RecordReader.java | 43 -
.../parquet/io/RecordReaderImplementation.java | 473 --------
.../parquet/io/ValidatingRecordConsumer.java | 230 ----
.../src/main/java/parquet/io/api/Binary.java | 414 -------
.../src/main/java/parquet/io/api/Converter.java | 40 -
.../java/parquet/io/api/GroupConverter.java | 58 -
.../java/parquet/io/api/PrimitiveConverter.java | 111 --
.../java/parquet/io/api/RecordConsumer.java | 128 ---
.../java/parquet/io/api/RecordMaterializer.java | 48 -
.../java/parquet/schema/ConversionPatterns.java | 104 --
.../java/parquet/schema/DecimalMetadata.java | 57 -
.../src/main/java/parquet/schema/GroupType.java | 391 -------
...IncompatibleSchemaModificationException.java | 49 -
.../main/java/parquet/schema/MessageType.java | 148 ---
.../java/parquet/schema/MessageTypeParser.java | 216 ----
.../main/java/parquet/schema/OriginalType.java | 42 -
.../main/java/parquet/schema/PrimitiveType.java | 530 ---------
.../src/main/java/parquet/schema/Type.java | 317 ------
.../main/java/parquet/schema/TypeConverter.java | 55 -
.../main/java/parquet/schema/TypeVisitor.java | 46 -
.../src/main/java/parquet/schema/Types.java | 668 -----------
.../column/impl/TestColumnReaderImpl.java | 123 +++
.../parquet/column/mem/TestMemColumn.java | 164 +++
.../parquet/column/mem/TestMemPageStore.java | 61 ++
.../parquet/column/page/mem/MemPageReader.java | 69 ++
.../parquet/column/page/mem/MemPageStore.java | 77 ++
.../parquet/column/page/mem/MemPageWriter.java | 113 ++
.../column/statistics/TestStatistics.java | 569 ++++++++++
.../apache/parquet/column/values/RandomStr.java | 56 +
.../org/apache/parquet/column/values/Utils.java | 90 ++
.../values/bitpacking/BitPackingPerfTest.java | 103 ++
.../values/bitpacking/TestBitPackingColumn.java | 208 ++++
.../values/boundedint/TestBoundedColumns.java | 172 +++
.../DeltaBinaryPackingValuesWriterTest.java | 262 +++++
.../values/delta/benchmark/BenchMarkTest.java | 43 +
.../benchmark/BenchmarkIntegerOutputSize.java | 102 ++
.../BenchmarkReadingRandomIntegers.java | 96 ++
.../benchmark/RandomWritingBenchmarkTest.java | 70 ++
.../SmallRangeWritingBenchmarkTest.java | 48 +
.../TestDeltaLengthByteArray.java | 74 ++
.../BenchmarkDeltaLengthByteArray.java | 71 ++
.../values/deltastrings/TestDeltaByteArray.java | 84 ++
.../benchmark/BenchmarkDeltaByteArray.java | 101 ++
.../values/dictionary/TestDictionary.java | 531 +++++++++
...unLengthBitPackingHybridIntegrationTest.java | 99 ++
.../TestRunLengthBitPackingHybridEncoder.java | 322 ++++++
.../parquet/filter2/predicate/DummyUdp.java | 37 +
.../filter2/predicate/TestFilterApiMethods.java | 172 +++
.../predicate/TestLogicalInverseRewriter.java | 103 ++
.../filter2/predicate/TestLogicalInverter.java | 94 ++
.../TestSchemaCompatibilityValidator.java | 142 +++
.../filter2/predicate/TestValidTypeMap.java | 111 ++
...mentallyUpdatedFilterPredicateEvaluator.java | 209 ++++
...ementallyUpdatedFilterPredicateResetter.java | 69 ++
.../filter2/recordlevel/TestValueInspector.java | 97 ++
.../apache/parquet/io/ConverterConsumer.java | 117 ++
.../io/ExpectationValidatingConverter.java | 169 +++
.../io/ExpectationValidatingRecordConsumer.java | 104 ++
.../java/org/apache/parquet/io/PerfTest.java | 132 +++
.../org/apache/parquet/io/TestColumnIO.java | 674 ++++++++++++
.../org/apache/parquet/io/TestFiltered.java | 270 +++++
.../parquet/parser/TestParquetParser.java | 313 ++++++
.../apache/parquet/schema/TestMessageType.java | 148 +++
.../apache/parquet/schema/TestTypeBuilders.java | 619 +++++++++++
.../column/impl/TestColumnReaderImpl.java | 123 ---
.../java/parquet/column/mem/TestMemColumn.java | 164 ---
.../parquet/column/mem/TestMemPageStore.java | 61 --
.../parquet/column/page/mem/MemPageReader.java | 69 --
.../parquet/column/page/mem/MemPageStore.java | 77 --
.../parquet/column/page/mem/MemPageWriter.java | 114 --
.../column/statistics/TestStatistics.java | 569 ----------
.../java/parquet/column/values/RandomStr.java | 56 -
.../test/java/parquet/column/values/Utils.java | 90 --
.../values/bitpacking/BitPackingPerfTest.java | 103 --
.../values/bitpacking/TestBitPackingColumn.java | 208 ----
.../values/boundedint/TestBoundedColumns.java | 175 ---
.../DeltaBinaryPackingValuesWriterTest.java | 262 -----
.../values/delta/benchmark/BenchMarkTest.java | 43 -
.../benchmark/BenchmarkIntegerOutputSize.java | 102 --
.../BenchmarkReadingRandomIntegers.java | 96 --
.../benchmark/RandomWritingBenchmarkTest.java | 70 --
.../SmallRangeWritingBenchmarkTest.java | 48 -
.../TestDeltaLengthByteArray.java | 74 --
.../BenchmarkDeltaLengthByteArray.java | 71 --
.../values/deltastrings/TestDeltaByteArray.java | 84 --
.../benchmark/BenchmarkDeltaByteArray.java | 101 --
.../values/dictionary/TestDictionary.java | 531 ---------
...unLengthBitPackingHybridIntegrationTest.java | 100 --
.../TestRunLengthBitPackingHybridEncoder.java | 322 ------
.../parquet/filter2/predicate/DummyUdp.java | 37 -
.../filter2/predicate/TestFilterApiMethods.java | 172 ---
.../predicate/TestLogicalInverseRewriter.java | 103 --
.../filter2/predicate/TestLogicalInverter.java | 94 --
.../TestSchemaCompatibilityValidator.java | 142 ---
.../filter2/predicate/TestValidTypeMap.java | 111 --
...mentallyUpdatedFilterPredicateEvaluator.java | 209 ----
...ementallyUpdatedFilterPredicateResetter.java | 69 --
.../filter2/recordlevel/TestValueInspector.java | 97 --
.../test/java/parquet/io/ConverterConsumer.java | 117 --
.../io/ExpectationValidatingConverter.java | 169 ---
.../io/ExpectationValidatingRecordConsumer.java | 105 --
.../src/test/java/parquet/io/PerfTest.java | 132 ---
.../src/test/java/parquet/io/TestColumnIO.java | 674 ------------
.../src/test/java/parquet/io/TestFiltered.java | 270 -----
.../java/parquet/parser/TestParquetParser.java | 313 ------
.../java/parquet/schema/TestMessageType.java | 148 ---
.../java/parquet/schema/TestTypeBuilders.java | 619 -----------
parquet-common/pom.xml | 2 +-
.../java/org/apache/parquet/Closeables.java | 55 +
.../src/main/java/org/apache/parquet/Ints.java | 44 +
.../src/main/java/org/apache/parquet/Log.java | 206 ++++
.../apache/parquet/ParquetRuntimeException.java | 46 +
.../java/org/apache/parquet/Preconditions.java | 123 +++
.../main/java/org/apache/parquet/Version.java | 103 ++
.../org/apache/parquet/bytes/BytesUtils.java | 269 +++++
.../parquet/hadoop/metadata/Canonicalizer.java | 62 ++
.../parquet/hadoop/metadata/ColumnPath.java | 97 ++
.../src/main/java/parquet/Closeables.java | 55 -
parquet-common/src/main/java/parquet/Ints.java | 44 -
parquet-common/src/main/java/parquet/Log.java | 206 ----
.../java/parquet/ParquetRuntimeException.java | 46 -
.../src/main/java/parquet/Preconditions.java | 123 ---
.../src/main/java/parquet/Version.java | 103 --
.../src/main/java/parquet/bytes/BytesUtils.java | 269 -----
.../parquet/hadoop/metadata/Canonicalizer.java | 62 --
.../parquet/hadoop/metadata/ColumnPath.java | 97 --
.../test/java/org/apache/parquet/TestLog.java | 31 +
.../org/apache/parquet/TestPreconditions.java | 58 +
.../org/apache/parquet/bytes/TestBytesUtil.java | 49 +
.../src/test/java/parquet/TestLog.java | 31 -
.../test/java/parquet/TestPreconditions.java | 58 -
.../test/java/parquet/bytes/TestBytesUtil.java | 49 -
parquet-encoding/pom.xml | 8 +-
.../org/apache/parquet/bytes/BytesInput.java | 365 ++++++
.../bytes/CapacityByteArrayOutputStream.java | 276 +++++
.../bytes/ConcatenatingByteArrayCollector.java | 63 ++
.../bytes/LittleEndianDataInputStream.java | 424 +++++++
.../bytes/LittleEndianDataOutputStream.java | 213 ++++
.../column/values/bitpacking/BitPacking.java | 725 ++++++++++++
.../bitpacking/ByteBasedBitPackingEncoder.java | 130 +++
.../column/values/bitpacking/BytePacker.java | 86 ++
.../values/bitpacking/BytePackerFactory.java | 25 +
.../column/values/bitpacking/IntPacker.java | 66 ++
.../values/bitpacking/IntPackerFactory.java | 25 +
.../column/values/bitpacking/Packer.java | 99 ++
.../src/main/java/parquet/bytes/BytesInput.java | 365 ------
.../bytes/CapacityByteArrayOutputStream.java | 276 -----
.../bytes/ConcatenatingByteArrayCollector.java | 63 --
.../bytes/LittleEndianDataInputStream.java | 424 -------
.../bytes/LittleEndianDataOutputStream.java | 213 ----
.../column/values/bitpacking/BitPacking.java | 725 ------------
.../bitpacking/ByteBasedBitPackingEncoder.java | 130 ---
.../column/values/bitpacking/BytePacker.java | 86 --
.../values/bitpacking/BytePackerFactory.java | 25 -
.../column/values/bitpacking/IntPacker.java | 66 --
.../values/bitpacking/IntPackerFactory.java | 25 -
.../column/values/bitpacking/Packer.java | 99 --
.../TestCapacityByteArrayOutputStream.java | 242 ++++
.../values/bitpacking/TestBitPacking.java | 218 ++++
.../TestByteBasedBitPackingEncoder.java | 40 +
.../values/bitpacking/TestByteBitPacking.java | 150 +++
.../values/bitpacking/TestLemireBitPacking.java | 123 +++
.../TestCapacityByteArrayOutputStream.java | 242 ----
.../values/bitpacking/TestBitPacking.java | 218 ----
.../TestByteBasedBitPackingEncoder.java | 40 -
.../values/bitpacking/TestByteBitPacking.java | 151 ---
.../values/bitpacking/TestLemireBitPacking.java | 123 ---
parquet-generator/pom.xml | 4 +-
.../org/apache/parquet/encoding/Generator.java | 37 +
.../ByteBasedBitPackingGenerator.java | 259 +++++
.../bitpacking/IntBasedBitPackingGenerator.java | 211 ++++
.../org/apache/parquet/filter2/Generator.java | 28 +
...mentallyUpdatedFilterPredicateGenerator.java | 269 +++++
.../main/java/parquet/encoding/Generator.java | 37 -
.../ByteBasedBitPackingGenerator.java | 259 -----
.../bitpacking/IntBasedBitPackingGenerator.java | 211 ----
.../main/java/parquet/filter2/Generator.java | 28 -
...mentallyUpdatedFilterPredicateGenerator.java | 269 -----
parquet-hadoop-bundle/pom.xml | 10 +-
.../main/resources/org/apache/parquet/bundle | 18 +
.../src/main/resources/parquet/bundle | 18 -
parquet-hadoop/pom.xml | 8 +-
.../parquet/filter2/compat/RowGroupFilter.java | 81 ++
.../statisticslevel/StatisticsFilter.java | 305 ++++++
.../converter/ParquetMetadataConverter.java | 735 +++++++++++++
.../hadoop/BadConfigurationException.java | 47 +
.../org/apache/parquet/hadoop/CodecFactory.java | 195 ++++
.../hadoop/ColumnChunkPageReadStore.java | 170 +++
.../hadoop/ColumnChunkPageWriteStore.java | 242 ++++
.../java/org/apache/parquet/hadoop/Footer.java | 57 +
.../hadoop/InternalParquetRecordReader.java | 244 +++++
.../hadoop/InternalParquetRecordWriter.java | 175 +++
.../org/apache/parquet/hadoop/LruCache.java | 199 ++++
.../apache/parquet/hadoop/MemoryManager.java | 158 +++
.../parquet/hadoop/ParquetFileReader.java | 782 +++++++++++++
.../parquet/hadoop/ParquetFileWriter.java | 553 ++++++++++
.../parquet/hadoop/ParquetInputFormat.java | 778 +++++++++++++
.../parquet/hadoop/ParquetInputSplit.java | 294 +++++
.../parquet/hadoop/ParquetOutputCommitter.java | 72 ++
.../parquet/hadoop/ParquetOutputFormat.java | 353 ++++++
.../apache/parquet/hadoop/ParquetReader.java | 195 ++++
.../parquet/hadoop/ParquetRecordReader.java | 217 ++++
.../parquet/hadoop/ParquetRecordWriter.java | 126 +++
.../apache/parquet/hadoop/ParquetWriter.java | 272 +++++
.../org/apache/parquet/hadoop/PrintFooter.java | 271 +++++
.../hadoop/api/DelegatingReadSupport.java | 62 ++
.../hadoop/api/DelegatingWriteSupport.java | 66 ++
.../apache/parquet/hadoop/api/InitContext.java | 102 ++
.../apache/parquet/hadoop/api/ReadSupport.java | 150 +++
.../apache/parquet/hadoop/api/WriteSupport.java | 131 +++
.../apache/parquet/hadoop/api/package-info.java | 27 +
.../parquet/hadoop/codec/CodecConfig.java | 169 +++
.../CompressionCodecNotSupportedException.java | 36 +
.../codec/NonBlockedCompressorStream.java | 50 +
.../codec/NonBlockedDecompressorStream.java | 57 +
.../parquet/hadoop/codec/SnappyCodec.java | 105 ++
.../parquet/hadoop/codec/SnappyCompressor.java | 161 +++
.../hadoop/codec/SnappyDecompressor.java | 150 +++
.../apache/parquet/hadoop/codec/SnappyUtil.java | 33 +
.../hadoop/example/ExampleInputFormat.java | 38 +
.../hadoop/example/ExampleOutputFormat.java | 62 ++
.../hadoop/example/GroupReadSupport.java | 49 +
.../hadoop/example/GroupWriteSupport.java | 67 ++
.../apache/parquet/hadoop/mapred/Container.java | 37 +
.../mapred/DeprecatedParquetInputFormat.java | 208 ++++
.../mapred/DeprecatedParquetOutputFormat.java | 119 ++
.../mapred/MapredParquetOutputCommitter.java | 45 +
.../parquet/hadoop/metadata/BlockMetaData.java | 123 +++
.../hadoop/metadata/ColumnChunkMetaData.java | 389 +++++++
.../hadoop/metadata/ColumnChunkProperties.java | 89 ++
.../hadoop/metadata/CompressionCodecName.java | 93 ++
.../parquet/hadoop/metadata/EncodingList.java | 81 ++
.../parquet/hadoop/metadata/FileMetaData.java | 83 ++
.../parquet/hadoop/metadata/GlobalMetaData.java | 106 ++
.../hadoop/metadata/ParquetMetadata.java | 132 +++
.../org/apache/parquet/hadoop/package-info.java | 35 +
.../parquet/hadoop/util/ConfigurationUtil.java | 44 +
.../apache/parquet/hadoop/util/ContextUtil.java | 275 +++++
.../parquet/hadoop/util/HiddenFileFilter.java | 33 +
.../parquet/hadoop/util/SerializationUtil.java | 111 ++
.../hadoop/util/counters/BenchmarkCounter.java | 114 ++
.../hadoop/util/counters/CounterLoader.java | 28 +
.../parquet/hadoop/util/counters/ICounter.java | 29 +
.../counters/mapred/MapRedCounterAdapter.java | 44 +
.../counters/mapred/MapRedCounterLoader.java | 52 +
.../mapreduce/MapReduceCounterAdapter.java | 45 +
.../mapreduce/MapReduceCounterLoader.java | 47 +
.../parquet/filter2/compat/RowGroupFilter.java | 81 --
.../statisticslevel/StatisticsFilter.java | 305 ------
.../converter/ParquetMetadataConverter.java | 735 -------------
.../hadoop/BadConfigurationException.java | 47 -
.../main/java/parquet/hadoop/CodecFactory.java | 195 ----
.../hadoop/ColumnChunkPageReadStore.java | 170 ---
.../hadoop/ColumnChunkPageWriteStore.java | 242 ----
.../src/main/java/parquet/hadoop/Footer.java | 57 -
.../hadoop/InternalParquetRecordReader.java | 244 -----
.../hadoop/InternalParquetRecordWriter.java | 175 ---
.../src/main/java/parquet/hadoop/LruCache.java | 199 ----
.../main/java/parquet/hadoop/MemoryManager.java | 158 ---
.../java/parquet/hadoop/ParquetFileReader.java | 782 -------------
.../java/parquet/hadoop/ParquetFileWriter.java | 553 ----------
.../java/parquet/hadoop/ParquetInputFormat.java | 778 -------------
.../java/parquet/hadoop/ParquetInputSplit.java | 294 -----
.../parquet/hadoop/ParquetOutputCommitter.java | 72 --
.../parquet/hadoop/ParquetOutputFormat.java | 353 ------
.../main/java/parquet/hadoop/ParquetReader.java | 195 ----
.../parquet/hadoop/ParquetRecordReader.java | 217 ----
.../parquet/hadoop/ParquetRecordWriter.java | 126 ---
.../main/java/parquet/hadoop/ParquetWriter.java | 272 -----
.../main/java/parquet/hadoop/PrintFooter.java | 271 -----
.../hadoop/api/DelegatingReadSupport.java | 62 --
.../hadoop/api/DelegatingWriteSupport.java | 66 --
.../java/parquet/hadoop/api/InitContext.java | 102 --
.../java/parquet/hadoop/api/ReadSupport.java | 150 ---
.../java/parquet/hadoop/api/WriteSupport.java | 131 ---
.../java/parquet/hadoop/api/package-info.java | 27 -
.../java/parquet/hadoop/codec/CodecConfig.java | 169 ---
.../CompressionCodecNotSupportedException.java | 36 -
.../codec/NonBlockedCompressorStream.java | 50 -
.../codec/NonBlockedDecompressorStream.java | 57 -
.../java/parquet/hadoop/codec/SnappyCodec.java | 105 --
.../parquet/hadoop/codec/SnappyCompressor.java | 161 ---
.../hadoop/codec/SnappyDecompressor.java | 150 ---
.../java/parquet/hadoop/codec/SnappyUtil.java | 33 -
.../hadoop/example/ExampleInputFormat.java | 38 -
.../hadoop/example/ExampleOutputFormat.java | 62 --
.../hadoop/example/GroupReadSupport.java | 49 -
.../hadoop/example/GroupWriteSupport.java | 67 --
.../java/parquet/hadoop/mapred/Container.java | 37 -
.../mapred/DeprecatedParquetInputFormat.java | 208 ----
.../mapred/DeprecatedParquetOutputFormat.java | 119 --
.../mapred/MapredParquetOutputCommitter.java | 45 -
.../parquet/hadoop/metadata/BlockMetaData.java | 123 ---
.../hadoop/metadata/ColumnChunkMetaData.java | 389 -------
.../hadoop/metadata/ColumnChunkProperties.java | 89 --
.../hadoop/metadata/CompressionCodecName.java | 93 --
.../parquet/hadoop/metadata/EncodingList.java | 81 --
.../parquet/hadoop/metadata/FileMetaData.java | 83 --
.../parquet/hadoop/metadata/GlobalMetaData.java | 106 --
.../hadoop/metadata/ParquetMetadata.java | 132 ---
.../main/java/parquet/hadoop/package-info.java | 35 -
.../parquet/hadoop/util/ConfigurationUtil.java | 44 -
.../java/parquet/hadoop/util/ContextUtil.java | 275 -----
.../parquet/hadoop/util/HiddenFileFilter.java | 33 -
.../parquet/hadoop/util/SerializationUtil.java | 111 --
.../hadoop/util/counters/BenchmarkCounter.java | 114 --
.../hadoop/util/counters/CounterLoader.java | 28 -
.../parquet/hadoop/util/counters/ICounter.java | 29 -
.../counters/mapred/MapRedCounterAdapter.java | 44 -
.../counters/mapred/MapRedCounterLoader.java | 52 -
.../mapreduce/MapReduceCounterAdapter.java | 45 -
.../mapreduce/MapReduceCounterLoader.java | 47 -
.../filter2/compat/TestRowGroupFilter.java | 102 ++
.../filter2/recordlevel/PhoneBookWriter.java | 269 +++++
.../recordlevel/TestRecordLevelFilters.java | 276 +++++
.../statisticslevel/TestStatisticsFilter.java | 325 ++++++
.../converter/TestParquetMetadataConverter.java | 255 +++++
.../hadoop/DeprecatedInputFormatTest.java | 182 +++
.../hadoop/DeprecatedOutputFormatTest.java | 109 ++
.../hadoop/TestColumnChunkPageWriteStore.java | 180 +++
.../apache/parquet/hadoop/TestInputFormat.java | 498 +++++++++
.../org/apache/parquet/hadoop/TestLruCache.java | 162 +++
.../parquet/hadoop/TestMemoryManager.java | 106 ++
.../parquet/hadoop/TestParquetFileWriter.java | 499 +++++++++
.../parquet/hadoop/TestParquetWriter.java | 129 +++
.../hadoop/TestParquetWriterNewPage.java | 135 +++
.../apache/parquet/hadoop/TestSnappyCodec.java | 140 +++
.../org/apache/parquet/hadoop/TestUtils.java | 40 +
.../parquet/hadoop/codec/CodecConfigTest.java | 77 ++
.../hadoop/example/GroupReadSupportTest.java | 65 ++
.../hadoop/example/TestInputOutputFormat.java | 291 +++++
.../metadata/TestColumnChunkMetaData.java | 83 ++
.../hadoop/util/TestSerializationUtil.java | 71 ++
.../filter2/compat/TestRowGroupFilter.java | 102 --
.../filter2/recordlevel/PhoneBookWriter.java | 269 -----
.../recordlevel/TestRecordLevelFilters.java | 277 -----
.../statisticslevel/TestStatisticsFilter.java | 325 ------
.../converter/TestParquetMetadataConverter.java | 255 -----
.../hadoop/DeprecatedInputFormatTest.java | 182 ---
.../hadoop/DeprecatedOutputFormatTest.java | 109 --
.../hadoop/TestColumnChunkPageWriteStore.java | 180 ---
.../java/parquet/hadoop/TestInputFormat.java | 498 ---------
.../test/java/parquet/hadoop/TestLruCache.java | 162 ---
.../java/parquet/hadoop/TestMemoryManager.java | 106 --
.../parquet/hadoop/TestParquetFileWriter.java | 499 ---------
.../java/parquet/hadoop/TestParquetWriter.java | 129 ---
.../hadoop/TestParquetWriterNewPage.java | 135 ---
.../java/parquet/hadoop/TestSnappyCodec.java | 140 ---
.../src/test/java/parquet/hadoop/TestUtils.java | 40 -
.../parquet/hadoop/codec/CodecConfigTest.java | 77 --
.../hadoop/example/GroupReadSupportTest.java | 65 --
.../hadoop/example/TestInputOutputFormat.java | 291 -----
.../metadata/TestColumnChunkMetaData.java | 83 --
.../hadoop/util/TestSerializationUtil.java | 71 --
parquet-hive-bundle/pom.xml | 8 +-
.../main/resources/org/apache/parquet/bundle | 18 +
.../src/main/resources/parquet/bundle | 18 -
.../parquet-hive-0.10-binding/pom.xml | 6 +-
.../parquet/hive/internal/Hive010Binding.java | 166 +++
.../parquet/hive/internal/Hive010Binding.java | 166 ---
.../parquet-hive-0.12-binding/pom.xml | 6 +-
.../parquet/hive/internal/Hive012Binding.java | 167 +++
.../parquet/hive/internal/Hive012Binding.java | 167 ---
.../parquet-hive-binding-bundle/pom.xml | 12 +-
.../main/resources/org/apache/parquet/bundle | 18 +
.../src/main/resources/parquet/bundle | 18 -
.../parquet-hive-binding-factory/pom.xml | 10 +-
.../apache/parquet/hive/HiveBindingFactory.java | 159 +++
.../java/parquet/hive/HiveBindingFactory.java | 159 ---
.../parquet/hive/TestHiveBindingFactory.java | 139 +++
.../parquet/hive/TestHiveBindingFactory.java | 139 ---
.../parquet-hive-binding-interface/pom.xml | 2 +-
.../org/apache/parquet/hive/HiveBinding.java | 57 +
.../hive/internal/AbstractHiveBinding.java | 54 +
.../src/main/java/parquet/hive/HiveBinding.java | 57 -
.../hive/internal/AbstractHiveBinding.java | 54 -
parquet-hive/parquet-hive-binding/pom.xml | 2 +-
.../parquet-hive-storage-handler/pom.xml | 18 +-
.../ql/io/parquet/MapredParquetInputFormat.java | 2 +-
.../io/parquet/MapredParquetOutputFormat.java | 2 +-
.../convert/ArrayWritableGroupConverter.java | 6 +-
.../convert/DataWritableGroupConverter.java | 6 +-
.../convert/DataWritableRecordConverter.java | 6 +-
.../ql/io/parquet/convert/ETypeConverter.java | 10 +-
.../io/parquet/convert/HiveGroupConverter.java | 8 +-
.../io/parquet/convert/HiveSchemaConverter.java | 16 +-
.../parquet/read/DataWritableReadSupport.java | 22 +-
.../read/ParquetRecordReaderWrapper.java | 22 +-
.../ql/io/parquet/serde/ParquetHiveSerDe.java | 2 +-
.../ql/io/parquet/writable/BinaryWritable.java | 2 +-
.../parquet/write/DataWritableWriteSupport.java | 8 +-
.../ql/io/parquet/write/DataWritableWriter.java | 8 +-
.../write/ParquetRecordWriterWrapper.java | 4 +-
.../primitive/ParquetStringInspector.java | 2 +-
.../hive/DeprecatedParquetInputFormat.java | 42 +
.../hive/DeprecatedParquetOutputFormat.java | 41 +
.../parquet/hive/MapredParquetInputFormat.java | 41 +
.../parquet/hive/MapredParquetOutputFormat.java | 40 +
.../parquet/hive/serde/ParquetHiveSerDe.java | 30 +
.../hive/DeprecatedParquetInputFormat.java | 42 -
.../hive/DeprecatedParquetOutputFormat.java | 41 -
.../parquet/hive/MapredParquetInputFormat.java | 41 -
.../parquet/hive/MapredParquetOutputFormat.java | 40 -
.../parquet/hive/serde/ParquetHiveSerDe.java | 30 -
.../ql/io/parquet/TestHiveSchemaConverter.java | 12 +-
.../parquet/TestMapredParquetInputFormat.java | 2 +-
.../parquet/TestMapredParquetOutputFormat.java | 2 +-
.../hive/ql/io/parquet/TestParquetSerDe.java | 2 +-
parquet-hive/pom.xml | 2 +-
parquet-jackson/pom.xml | 2 +-
parquet-pig-bundle/pom.xml | 6 +-
.../main/resources/org/apache/parquet/bundle | 18 +
.../src/main/resources/parquet/bundle | 18 -
parquet-pig/pom.xml | 12 +-
.../org/apache/parquet/pig/ParquetLoader.java | 383 +++++++
.../org/apache/parquet/pig/ParquetStorer.java | 155 +++
.../org/apache/parquet/pig/PigMetaData.java | 94 ++
.../apache/parquet/pig/PigSchemaConverter.java | 514 +++++++++
.../parquet/pig/SchemaConversionException.java | 47 +
.../parquet/pig/TupleConversionException.java | 42 +
.../apache/parquet/pig/TupleReadSupport.java | 193 ++++
.../apache/parquet/pig/TupleWriteSupport.java | 206 ++++
.../parquet/pig/convert/MapConverter.java | 201 ++++
.../pig/convert/ParentValueContainer.java | 35 +
.../parquet/pig/convert/TupleConverter.java | 594 ++++++++++
.../pig/convert/TupleRecordMaterializer.java | 50 +
.../parquet/pig/summary/BagSummaryData.java | 80 ++
.../apache/parquet/pig/summary/EnumStat.java | 115 ++
.../parquet/pig/summary/FieldSummaryData.java | 184 ++++
.../parquet/pig/summary/MapSummaryData.java | 92 ++
.../parquet/pig/summary/NumberSummaryData.java | 50 +
.../parquet/pig/summary/StringSummaryData.java | 85 ++
.../org/apache/parquet/pig/summary/Summary.java | 283 +++++
.../apache/parquet/pig/summary/SummaryData.java | 159 +++
.../parquet/pig/summary/TupleSummaryData.java | 106 ++
.../apache/parquet/pig/summary/ValueStat.java | 64 ++
.../main/java/parquet/pig/ParquetLoader.java | 383 -------
.../main/java/parquet/pig/ParquetStorer.java | 155 ---
.../src/main/java/parquet/pig/PigMetaData.java | 94 --
.../java/parquet/pig/PigSchemaConverter.java | 514 ---------
.../parquet/pig/SchemaConversionException.java | 47 -
.../parquet/pig/TupleConversionException.java | 42 -
.../main/java/parquet/pig/TupleReadSupport.java | 193 ----
.../java/parquet/pig/TupleWriteSupport.java | 206 ----
.../java/parquet/pig/convert/MapConverter.java | 201 ----
.../pig/convert/ParentValueContainer.java | 35 -
.../parquet/pig/convert/TupleConverter.java | 594 ----------
.../pig/convert/TupleRecordMaterializer.java | 50 -
.../parquet/pig/summary/BagSummaryData.java | 80 --
.../main/java/parquet/pig/summary/EnumStat.java | 115 --
.../parquet/pig/summary/FieldSummaryData.java | 184 ----
.../parquet/pig/summary/MapSummaryData.java | 92 --
.../parquet/pig/summary/NumberSummaryData.java | 50 -
.../parquet/pig/summary/StringSummaryData.java | 85 --
.../main/java/parquet/pig/summary/Summary.java | 283 -----
.../java/parquet/pig/summary/SummaryData.java | 159 ---
.../parquet/pig/summary/TupleSummaryData.java | 106 --
.../java/parquet/pig/summary/ValueStat.java | 64 --
.../java/org/apache/parquet/pig/PerfTest.java | 108 ++
.../java/org/apache/parquet/pig/PerfTest2.java | 185 ++++
.../apache/parquet/pig/PerfTestReadAllCols.java | 51 +
.../apache/parquet/pig/TestParquetLoader.java | 334 ++++++
.../apache/parquet/pig/TestParquetStorer.java | 264 +++++
.../parquet/pig/TestPigSchemaConverter.java | 228 ++++
.../parquet/pig/TestTupleRecordConsumer.java | 209 ++++
.../parquet/pig/TupleConsumerPerfTest.java | 209 ++++
.../apache/parquet/pig/summary/TestSummary.java | 160 +++
.../src/test/java/parquet/pig/PerfTest.java | 111 --
.../src/test/java/parquet/pig/PerfTest2.java | 187 ----
.../java/parquet/pig/PerfTestReadAllCols.java | 51 -
.../java/parquet/pig/TestParquetLoader.java | 334 ------
.../java/parquet/pig/TestParquetStorer.java | 267 -----
.../parquet/pig/TestPigSchemaConverter.java | 231 ----
.../parquet/pig/TestTupleRecordConsumer.java | 209 ----
.../java/parquet/pig/TupleConsumerPerfTest.java | 209 ----
.../java/parquet/pig/summary/TestSummary.java | 160 ---
parquet-protobuf/pom.xml | 8 +-
.../parquet/proto/ProtoMessageConverter.java | 348 ++++++
.../parquet/proto/ProtoParquetInputFormat.java | 38 +
.../parquet/proto/ProtoParquetOutputFormat.java | 57 +
.../parquet/proto/ProtoParquetReader.java | 57 +
.../parquet/proto/ProtoParquetWriter.java | 81 ++
.../apache/parquet/proto/ProtoReadSupport.java | 80 ++
.../parquet/proto/ProtoRecordConverter.java | 84 ++
.../parquet/proto/ProtoRecordMaterializer.java | 44 +
.../parquet/proto/ProtoSchemaConverter.java | 107 ++
.../apache/parquet/proto/ProtoWriteSupport.java | 339 ++++++
.../parquet/proto/ProtoMessageConverter.java | 348 ------
.../parquet/proto/ProtoParquetInputFormat.java | 38 -
.../parquet/proto/ProtoParquetOutputFormat.java | 57 -
.../java/parquet/proto/ProtoParquetReader.java | 57 -
.../java/parquet/proto/ProtoParquetWriter.java | 81 --
.../java/parquet/proto/ProtoReadSupport.java | 80 --
.../parquet/proto/ProtoRecordConverter.java | 84 --
.../parquet/proto/ProtoRecordMaterializer.java | 44 -
.../parquet/proto/ProtoSchemaConverter.java | 107 --
.../java/parquet/proto/ProtoWriteSupport.java | 339 ------
.../proto/ProtoInputOutputFormatTest.java | 106 ++
.../parquet/proto/ProtoRecordConverterTest.java | 224 ++++
.../parquet/proto/ProtoSchemaConverterTest.java | 97 ++
.../parquet/proto/ProtoWriteSupportTest.java | 168 +++
.../org/apache/parquet/proto/TestUtils.java | 188 ++++
.../apache/parquet/proto/utils/ReadUsingMR.java | 87 ++
.../parquet/proto/utils/WriteUsingMR.java | 113 ++
.../proto/ProtoInputOutputFormatTest.java | 106 --
.../parquet/proto/ProtoRecordConverterTest.java | 224 ----
.../parquet/proto/ProtoSchemaConverterTest.java | 97 --
.../parquet/proto/ProtoWriteSupportTest.java | 168 ---
.../src/test/java/parquet/proto/TestUtils.java | 188 ----
.../java/parquet/proto/utils/ReadUsingMR.java | 87 --
.../java/parquet/proto/utils/WriteUsingMR.java | 113 --
.../src/test/resources/TestProtobuf.proto | 2 +-
parquet-scala/pom.xml | 4 +-
.../org/apache/parquet/filter2/dsl/Dsl.scala | 112 ++
.../main/scala/parquet/filter2/dsl/Dsl.scala | 112 --
.../apache/parquet/filter2/dsl/DslTest.scala | 87 ++
.../scala/parquet/filter2/dsl/DslTest.scala | 87 --
parquet-scrooge/pom.xml | 24 +-
.../scrooge/ParquetScroogeInputFormat.java | 31 +
.../scrooge/ParquetScroogeOutputFormat.java | 39 +
.../parquet/scrooge/ParquetScroogeScheme.java | 69 ++
.../parquet/scrooge/ScroogeReadSupport.java | 45 +
.../parquet/scrooge/ScroogeRecordConverter.java | 57 +
.../ScroogeSchemaConversionException.java | 36 +
.../parquet/scrooge/ScroogeStructConverter.java | 332 ++++++
.../parquet/scrooge/ScroogeWriteSupport.java | 65 ++
.../scrooge/ParquetScroogeInputFormat.java | 31 -
.../scrooge/ParquetScroogeOutputFormat.java | 39 -
.../parquet/scrooge/ParquetScroogeScheme.java | 69 --
.../parquet/scrooge/ScroogeReadSupport.java | 45 -
.../parquet/scrooge/ScroogeRecordConverter.java | 57 -
.../ScroogeSchemaConversionException.java | 36 -
.../parquet/scrooge/ScroogeStructConverter.java | 332 ------
.../parquet/scrooge/ScroogeWriteSupport.java | 65 --
.../scrooge/ParquetScroogeSchemeTest.java | 237 ++++
.../parquet/scrooge/ScroogeBinaryTest.java | 100 ++
.../scrooge/ScroogeStructConverterTest.java | 123 +++
.../scrooge/ParquetScroogeSchemeTest.java | 237 ----
.../java/parquet/scrooge/ScroogeBinaryTest.java | 100 --
.../scrooge/ScroogeStructConverterTest.java | 123 ---
parquet-scrooge/src/test/thrift/test.thrift | 2 +-
parquet-thrift/pom.xml | 12 +-
.../thrift/AbstractThriftWriteSupport.java | 125 +++
.../thrift/ParquetThriftBytesOutputFormat.java | 73 ++
.../hadoop/thrift/ParquetThriftInputFormat.java | 64 ++
.../thrift/ParquetThriftOutputFormat.java | 46 +
.../hadoop/thrift/TBaseWriteSupport.java | 62 ++
.../hadoop/thrift/ThriftBytesWriteSupport.java | 162 +++
.../hadoop/thrift/ThriftReadSupport.java | 180 +++
.../thrift/ThriftToParquetFileWriter.java | 125 +++
.../hadoop/thrift/ThriftWriteSupport.java | 75 ++
.../thrift/BufferedProtocolReadToWrite.java | 680 ++++++++++++
.../thrift/DecodingSchemaMismatchException.java | 30 +
.../parquet/thrift/FieldIgnoredHandler.java | 46 +
.../apache/parquet/thrift/ParquetProtocol.java | 280 +++++
.../parquet/thrift/ParquetReadProtocol.java | 161 +++
.../parquet/thrift/ParquetWriteProtocol.java | 690 ++++++++++++
.../org/apache/parquet/thrift/ProtocolPipe.java | 32 +
.../parquet/thrift/ProtocolReadToWrite.java | 145 +++
.../parquet/thrift/SkippableException.java | 50 +
.../parquet/thrift/TBaseRecordConverter.java | 48 +
.../apache/parquet/thrift/ThriftMetaData.java | 134 +++
.../parquet/thrift/ThriftParquetReader.java | 138 +++
.../parquet/thrift/ThriftParquetWriter.java | 54 +
.../org/apache/parquet/thrift/ThriftReader.java | 28 +
.../parquet/thrift/ThriftRecordConverter.java | 883 +++++++++++++++
.../thrift/ThriftSchemaConvertVisitor.java | 276 +++++
.../parquet/thrift/ThriftSchemaConverter.java | 165 +++
.../parquet/thrift/pig/ParquetThriftStorer.java | 93 ++
.../thrift/pig/TupleToThriftWriteSupport.java | 77 ++
.../projection/FieldProjectionFilter.java | 93 ++
.../parquet/thrift/projection/FieldsPath.java | 84 ++
.../thrift/projection/PathGlobPattern.java | 184 ++++
.../projection/ThriftProjectionException.java | 48 +
.../projection/amend/DefaultEventsVisitor.java | 215 ++++
.../amend/DefaultProtocolEventsGenerator.java | 68 ++
.../projection/amend/ProtocolEventsAmender.java | 173 +++
.../amend/ReadFieldBeginProtocol.java | 44 +
.../thrift/struct/CompatibilityChecker.java | 221 ++++
.../thrift/struct/CompatibilityRunner.java | 99 ++
.../org/apache/parquet/thrift/struct/JSON.java | 51 +
.../parquet/thrift/struct/ThriftField.java | 121 ++
.../parquet/thrift/struct/ThriftType.java | 578 ++++++++++
.../parquet/thrift/struct/ThriftTypeID.java | 111 ++
.../thrift/AbstractThriftWriteSupport.java | 126 ---
.../thrift/ParquetThriftBytesOutputFormat.java | 73 --
.../hadoop/thrift/ParquetThriftInputFormat.java | 64 --
.../thrift/ParquetThriftOutputFormat.java | 46 -
.../hadoop/thrift/TBaseWriteSupport.java | 63 --
.../hadoop/thrift/ThriftBytesWriteSupport.java | 162 ---
.../hadoop/thrift/ThriftReadSupport.java | 180 ---
.../thrift/ThriftToParquetFileWriter.java | 125 ---
.../hadoop/thrift/ThriftWriteSupport.java | 78 --
.../thrift/BufferedProtocolReadToWrite.java | 680 ------------
.../thrift/DecodingSchemaMismatchException.java | 30 -
.../parquet/thrift/FieldIgnoredHandler.java | 46 -
.../java/parquet/thrift/ParquetProtocol.java | 280 -----
.../parquet/thrift/ParquetReadProtocol.java | 161 ---
.../parquet/thrift/ParquetWriteProtocol.java | 692 ------------
.../main/java/parquet/thrift/ProtocolPipe.java | 32 -
.../parquet/thrift/ProtocolReadToWrite.java | 145 ---
.../java/parquet/thrift/SkippableException.java | 50 -
.../parquet/thrift/TBaseRecordConverter.java | 48 -
.../java/parquet/thrift/ThriftMetaData.java | 136 ---
.../parquet/thrift/ThriftParquetReader.java | 138 ---
.../parquet/thrift/ThriftParquetWriter.java | 54 -
.../main/java/parquet/thrift/ThriftReader.java | 28 -
.../parquet/thrift/ThriftRecordConverter.java | 883 ---------------
.../thrift/ThriftSchemaConvertVisitor.java | 276 -----
.../parquet/thrift/ThriftSchemaConverter.java | 165 ---
.../parquet/thrift/pig/ParquetThriftStorer.java | 93 --
.../thrift/pig/TupleToThriftWriteSupport.java | 77 --
.../projection/FieldProjectionFilter.java | 93 --
.../parquet/thrift/projection/FieldsPath.java | 84 --
.../thrift/projection/PathGlobPattern.java | 184 ----
.../projection/ThriftProjectionException.java | 48 -
.../projection/amend/DefaultEventsVisitor.java | 215 ----
.../amend/DefaultProtocolEventsGenerator.java | 68 --
.../projection/amend/ProtocolEventsAmender.java | 173 ---
.../amend/ReadFieldBeginProtocol.java | 44 -
.../thrift/struct/CompatibilityChecker.java | 221 ----
.../thrift/struct/CompatibilityRunner.java | 99 --
.../main/java/parquet/thrift/struct/JSON.java | 51 -
.../java/parquet/thrift/struct/ThriftField.java | 121 --
.../java/parquet/thrift/struct/ThriftType.java | 578 ----------
.../parquet/thrift/struct/ThriftTypeID.java | 111 --
.../parquet/hadoop/thrift/TestBinary.java | 66 ++
.../hadoop/thrift/TestInputOutputFormat.java | 257 +++++
...stParquetToThriftReadWriteAndProjection.java | 244 +++++
.../thrift/TestThriftToParquetFileWriter.java | 294 +++++
.../parquet/thrift/TestParquetReadProtocol.java | 167 +++
.../thrift/TestParquetWriteProtocol.java | 550 ++++++++++
.../parquet/thrift/TestProtocolReadToWrite.java | 286 +++++
.../thrift/TestThriftParquetReaderWriter.java | 73 ++
.../thrift/TestThriftSchemaConverter.java | 250 +++++
.../thrift/TestThriftToPigCompatibility.java | 171 +++
.../thrift/pig/TestParquetThriftStorer.java | 82 ++
.../thrift/projection/PathGlobPatternTest.java | 59 +
.../thrift/struct/CompatibilityCheckerTest.java | 120 ++
.../parquet/thrift/struct/TestThriftType.java | 67 ++
.../java/parquet/hadoop/thrift/TestBinary.java | 66 --
.../hadoop/thrift/TestInputOutputFormat.java | 257 -----
...stParquetToThriftReadWriteAndProjection.java | 244 -----
.../thrift/TestThriftToParquetFileWriter.java | 294 -----
.../parquet/thrift/TestParquetReadProtocol.java | 167 ---
.../thrift/TestParquetWriteProtocol.java | 550 ----------
.../parquet/thrift/TestProtocolReadToWrite.java | 286 -----
.../thrift/TestThriftParquetReaderWriter.java | 73 --
.../thrift/TestThriftSchemaConverter.java | 250 -----
.../thrift/TestThriftToPigCompatibility.java | 171 ---
.../thrift/pig/TestParquetThriftStorer.java | 82 --
.../thrift/projection/PathGlobPatternTest.java | 59 -
.../thrift/struct/CompatibilityCheckerTest.java | 120 --
.../parquet/thrift/struct/TestThriftType.java | 67 --
.../parquet/hadoop/thrift/AddressBook.json | 96 ++
.../parquet/hadoop/thrift/AddressBook.json | 96 --
parquet-thrift/src/test/thrift/binary.thrift | 2 +-
parquet-thrift/src/test/thrift/compat.thrift | 4 +-
parquet-thrift/src/test/thrift/test.thrift | 2 +-
parquet-tools/pom.xml | 8 +-
.../java/org/apache/parquet/tools/Main.java | 231 ++++
.../parquet/tools/command/ArgsOnlyCommand.java | 56 +
.../parquet/tools/command/CatCommand.java | 91 ++
.../apache/parquet/tools/command/Command.java | 30 +
.../parquet/tools/command/DumpCommand.java | 338 ++++++
.../parquet/tools/command/HeadCommand.java | 95 ++
.../apache/parquet/tools/command/Registry.java | 60 +
.../parquet/tools/command/ShowMetaCommand.java | 76 ++
.../tools/command/ShowSchemaCommand.java | 100 ++
.../parquet/tools/read/SimpleListRecord.java | 30 +
.../tools/read/SimpleListRecordConverter.java | 34 +
.../parquet/tools/read/SimpleMapRecord.java | 43 +
.../tools/read/SimpleMapRecordConverter.java | 34 +
.../parquet/tools/read/SimpleReadSupport.java | 41 +
.../apache/parquet/tools/read/SimpleRecord.java | 149 +++
.../tools/read/SimpleRecordConverter.java | 159 +++
.../tools/read/SimpleRecordMaterializer.java | 42 +
.../parquet/tools/util/MetadataUtils.java | 229 ++++
.../parquet/tools/util/PrettyPrintWriter.java | 1035 ++++++++++++++++++
.../src/main/java/parquet/tools/Main.java | 231 ----
.../parquet/tools/command/ArgsOnlyCommand.java | 56 -
.../java/parquet/tools/command/CatCommand.java | 91 --
.../java/parquet/tools/command/Command.java | 30 -
.../java/parquet/tools/command/DumpCommand.java | 338 ------
.../java/parquet/tools/command/HeadCommand.java | 95 --
.../java/parquet/tools/command/Registry.java | 60 -
.../parquet/tools/command/ShowMetaCommand.java | 76 --
.../tools/command/ShowSchemaCommand.java | 100 --
.../parquet/tools/read/SimpleListRecord.java | 30 -
.../tools/read/SimpleListRecordConverter.java | 34 -
.../parquet/tools/read/SimpleMapRecord.java | 43 -
.../tools/read/SimpleMapRecordConverter.java | 34 -
.../parquet/tools/read/SimpleReadSupport.java | 41 -
.../java/parquet/tools/read/SimpleRecord.java | 149 ---
.../tools/read/SimpleRecordConverter.java | 159 ---
.../tools/read/SimpleRecordMaterializer.java | 42 -
.../java/parquet/tools/util/MetadataUtils.java | 229 ----
.../parquet/tools/util/PrettyPrintWriter.java | 1035 ------------------
parquet-tools/src/main/scripts/parquet-tools | 2 +-
pom.xml | 14 +-
1061 files changed, 75653 insertions(+), 75688 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/parquet-mr/blob/b10870e4/parquet-avro/pom.xml
----------------------------------------------------------------------
diff --git a/parquet-avro/pom.xml b/parquet-avro/pom.xml
index cd51961..6d71531 100644
--- a/parquet-avro/pom.xml
+++ b/parquet-avro/pom.xml
@@ -18,7 +18,7 @@
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
- <groupId>com.twitter</groupId>
+ <groupId>org.apache.parquet</groupId>
<artifactId>parquet</artifactId>
<relativePath>../pom.xml</relativePath>
<version>1.7.0-incubating-SNAPSHOT</version>
@@ -38,17 +38,17 @@
<dependencies>
<dependency>
- <groupId>com.twitter</groupId>
+ <groupId>org.apache.parquet</groupId>
<artifactId>parquet-column</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
- <groupId>com.twitter</groupId>
+ <groupId>org.apache.parquet</groupId>
<artifactId>parquet-hadoop</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
- <groupId>com.twitter</groupId>
+ <groupId>org.apache.parquet</groupId>
<artifactId>parquet-format</artifactId>
<version>${parquet.format.version}</version>
</dependency>
@@ -70,7 +70,7 @@
<scope>test</scope>
</dependency>
<dependency>
- <groupId>com.twitter</groupId>
+ <groupId>org.apache.parquet</groupId>
<artifactId>parquet-column</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
http://git-wip-us.apache.org/repos/asf/parquet-mr/blob/b10870e4/parquet-avro/src/main/java/org/apache/parquet/avro/AvroDataSupplier.java
----------------------------------------------------------------------
diff --git a/parquet-avro/src/main/java/org/apache/parquet/avro/AvroDataSupplier.java b/parquet-avro/src/main/java/org/apache/parquet/avro/AvroDataSupplier.java
new file mode 100644
index 0000000..de6465c
--- /dev/null
+++ b/parquet-avro/src/main/java/org/apache/parquet/avro/AvroDataSupplier.java
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.parquet.avro;
+
+import org.apache.avro.generic.GenericData;
+
+/**
+ * Allows clients to control how the classes associated
+ * with specific Avro records are managed and found, e.g.,
+ * by creating an instance of {@code GenericData} that
+ * uses a particular {@code ClassLoader}.
+ */
+public interface AvroDataSupplier {
+ GenericData get();
+}