You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dm...@apache.org on 2020/12/21 14:31:08 UTC
[hive] branch master updated (031b456 -> a97448f)
This is an automated email from the ASF dual-hosted git repository.
dmollitor pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git.
from 031b456 HIVE-24547: Fix acid_vectorization_original (Krisztian Kasa, reviewed by Zoltan Haindrich)
add a97448f HIVE-24332: Make AbstractSerDe Superclass of all SerDes (David Mollitor reviewed by Miklos Gergely)
No new revisions were added by this update.
Summary of changes:
.../hadoop/hive/accumulo/serde/AccumuloSerDe.java | 7 +-
.../hive/accumulo/serde/TestAccumuloSerDe.java | 26 ++---
.../serde/TestDefaultAccumuloRowIdFactory.java | 6 +-
.../hadoop/hive/contrib/serde2/RegexSerDe.java | 88 +++++++--------
.../hive/contrib/serde2/TypedBytesSerDe.java | 12 +-
.../hive/contrib/serde2/s3/S3LogDeserializer.java | 25 +++--
.../hadoop/hive/contrib/serde2/TestRegexSerDe.java | 3 +-
.../apache/hadoop/hive/druid/serde/DruidSerDe.java | 5 +-
.../hadoop/hive/druid/serde/TestDruidSerDe.java | 19 ++--
.../org/apache/hadoop/hive/hbase/HBaseSerDe.java | 24 ++--
.../apache/hadoop/hive/hbase/TestHBaseSerDe.java | 49 ++++----
.../apache/hive/hcatalog/data/HCatRecordSerDe.java | 17 ++-
.../org/apache/hive/hcatalog/data/JsonSerDe.java | 7 +-
.../hive/hcatalog/mapreduce/InternalUtil.java | 11 +-
.../hive/hcatalog/data/TestHCatRecordSerDe.java | 5 +-
.../apache/hive/hcatalog/data/TestJsonSerDe.java | 15 ++-
.../rcfile/TestRCFileMapReduceInputFormat.java | 3 +-
.../apache/hadoop/hive/serde2/CustomSerDe1.java | 14 ++-
.../apache/hadoop/hive/serde2/CustomSerDe2.java | 15 ++-
.../apache/hadoop/hive/serde2/CustomSerDe3.java | 22 ++--
.../apache/hadoop/hive/serde2/CustomSerDe4.java | 81 +++++++------
.../apache/hadoop/hive/serde2/CustomSerDe5.java | 81 ++++++-------
.../benchmark/storage/ColumnarStorageBench.java | 4 +-
.../apache/hadoop/hive/serde2/TestSysLogSerDe.java | 5 +-
.../org/apache/hadoop/hive/serde2/TestSerDe.java | 11 +-
.../org/apache/hive/storage/jdbc/JdbcSerDe.java | 47 ++++----
.../apache/hadoop/hive/kafka/KafkaJsonSerDe.java | 18 +--
.../org/apache/hadoop/hive/kafka/KafkaSerDe.java | 42 +++----
.../org/apache/hadoop/hive/kudu/KuduSerDe.java | 8 +-
.../org/apache/hadoop/hive/kudu/TestKuduSerDe.java | 8 +-
llap-client/pom.xml | 22 ++++
.../hadoop/hive/llap/LlapRowRecordReader.java | 2 +-
.../hadoop/hive/metastore/HiveMetaStoreUtils.java | 42 ++++---
.../ql/ddl/table/info/desc/DescTableOperation.java | 6 -
.../hive/ql/exec/AppMasterEventOperator.java | 8 +-
.../apache/hadoop/hive/ql/exec/DemuxOperator.java | 15 +--
.../apache/hadoop/hive/ql/exec/FetchOperator.java | 4 +-
.../hadoop/hive/ql/exec/FileSinkOperator.java | 7 +-
.../hive/ql/exec/HashTableDummyOperator.java | 9 +-
.../hadoop/hive/ql/exec/HashTableSinkOperator.java | 11 +-
.../org/apache/hadoop/hive/ql/exec/JoinUtil.java | 5 +-
.../hadoop/hive/ql/exec/MapJoinOperator.java | 13 +--
.../apache/hadoop/hive/ql/exec/MapOperator.java | 3 +-
.../hadoop/hive/ql/exec/ReduceSinkOperator.java | 14 ++-
.../apache/hadoop/hive/ql/exec/ScriptOperator.java | 17 ++-
.../hadoop/hive/ql/exec/SkewJoinHandler.java | 5 +-
.../org/apache/hadoop/hive/ql/exec/Utilities.java | 7 +-
.../apache/hadoop/hive/ql/exec/mr/ExecReducer.java | 23 ++--
.../ql/exec/spark/SparkDynamicPartitionPruner.java | 6 +-
.../ql/exec/spark/SparkReduceRecordHandler.java | 27 +++--
.../hive/ql/exec/tez/DynamicPartitionPruner.java | 7 +-
.../hive/ql/exec/tez/DynamicValueRegistryTez.java | 10 +-
.../hive/ql/exec/tez/ReduceRecordSource.java | 27 ++---
.../hive/ql/io/arrow/ArrowColumnarBatchSerDe.java | 23 ++--
.../apache/hadoop/hive/ql/io/arrow/Serializer.java | 7 +-
.../org/apache/hadoop/hive/ql/io/orc/OrcSerde.java | 14 ++-
.../hive/ql/io/parquet/serde/ParquetHiveSerDe.java | 19 ++--
.../ql/io/protobuf/ProtobufBytesWritableSerDe.java | 6 +-
.../hadoop/hive/ql/io/protobuf/ProtobufSerDe.java | 9 +-
.../hadoop/hive/ql/log/syslog/SyslogSerDe.java | 5 +-
.../hadoop/hive/ql/optimizer/GenMapRedUtils.java | 10 +-
.../TablePropertyEnrichmentOptimizer.java | 8 +-
.../hive/ql/optimizer/physical/Vectorizer.java | 18 +--
.../apache/hadoop/hive/ql/parse/PTFTranslator.java | 2 +-
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 5 +-
.../spark/SparkPartitionPruningSinkOperator.java | 2 +-
.../apache/hadoop/hive/ql/plan/MapJoinDesc.java | 12 +-
.../hadoop/hive/ql/plan/PTFDeserializer.java | 2 +-
.../apache/hadoop/hive/ql/plan/PartitionDesc.java | 10 +-
.../org/apache/hadoop/hive/ql/plan/TableDesc.java | 27 +++--
.../hadoop/hive/ql/exec/TestFileSinkOperator.java | 4 +-
.../persistence/TestMapJoinTableContainer.java | 5 +-
.../ql/exec/persistence/TestPTFRowContainer.java | 3 +-
.../hive/ql/exec/persistence/TestRowContainer.java | 3 +-
.../hadoop/hive/ql/exec/persistence/Utilities.java | 5 +-
.../ql/exec/vector/mapjoin/MapJoinTestConfig.java | 7 +-
.../org/apache/hadoop/hive/ql/io/TestRCFile.java | 5 +-
.../ql/io/arrow/TestArrowColumnarBatchSerDe.java | 3 +-
.../hive/ql/io/orc/TestInputOutputFormat.java | 15 ++-
.../ql/io/parquet/AbstractTestParquetDirect.java | 2 +-
.../hive/ql/io/parquet/TestDataWritableWriter.java | 3 +-
.../hive/ql/io/parquet/TestParquetSerDe.java | 5 +-
.../hive/ql/io/protobuf/TestProtoMessageSerDe.java | 4 +-
.../hadoop/hive/serde2/AbstractDeserializer.java | 68 -----------
.../hive/serde2/AbstractEncodingAwareSerDe.java | 7 +-
.../apache/hadoop/hive/serde2/AbstractSerDe.java | 125 +++++++++------------
.../hadoop/hive/serde2/AbstractSerializer.java | 65 -----------
.../hadoop/hive/serde2/DefaultFetchFormatter.java | 2 +-
.../apache/hadoop/hive/serde2/Deserializer.java | 22 +---
.../org/apache/hadoop/hive/serde2/JsonSerDe.java | 5 +-
.../hive/serde2/MetadataTypedColumnsetSerDe.java | 20 ++--
.../hadoop/hive/serde2/MultiDelimitSerDe.java | 16 +--
.../apache/hadoop/hive/serde2/NullStructSerDe.java | 3 +-
.../apache/hadoop/hive/serde2/OpenCSVSerde.java | 12 +-
.../org/apache/hadoop/hive/serde2/RegexSerDe.java | 19 ++--
.../serde2/{SerDeStatsStruct.java => SerDe.java} | 12 +-
.../org/apache/hadoop/hive/serde2/SerDeUtils.java | 42 -------
.../org/apache/hadoop/hive/serde2/Serializer.java | 26 +----
.../org/apache/hadoop/hive/serde2/TypedSerDe.java | 3 +-
.../apache/hadoop/hive/serde2/avro/AvroSerDe.java | 81 +++++++------
.../serde2/binarysortable/BinarySortableSerDe.java | 24 ++--
.../hadoop/hive/serde2/columnar/ColumnarSerDe.java | 17 ++-
.../serde2/columnar/LazyBinaryColumnarSerDe.java | 15 ++-
.../hadoop/hive/serde2/lazy/LazySimpleSerDe.java | 12 +-
.../hive/serde2/lazybinary/LazyBinarySerDe.java | 17 ++-
.../hive/serde2/lazybinary/LazyBinarySerDe2.java | 10 +-
.../hive/serde2/teradata/TeradataBinarySerde.java | 24 ++--
.../serde2/thrift/ThriftByteStreamTypedSerDe.java | 5 +-
.../hive/serde2/thrift/ThriftDeserializer.java | 23 +++-
.../hive/serde2/thrift/ThriftJDBCBinarySerDe.java | 16 +--
.../hadoop/hive/serde2/TestOpenCSVSerde.java | 6 +-
.../apache/hadoop/hive/serde2/TestStatsSerde.java | 6 +-
.../hadoop/hive/serde2/avro/TestAvroSerde.java | 7 +-
.../binarysortable/TestBinarySortableSerDe.java | 2 +-
.../columnar/TestLazyBinaryColumnarSerDe.java | 16 +--
.../hive/serde2/lazy/TestLazyArrayMapStruct.java | 2 +-
.../hive/serde2/lazy/TestLazySimpleFast.java | 3 +-
.../hive/serde2/lazy/TestLazySimpleSerDe.java | 11 +-
.../serde2/lazybinary/TestLazyBinarySerDe.java | 2 +-
.../serde2/lazybinary/TestLazyBinarySerDe2.java | 6 +-
.../serde2/lazybinary/TestLazyBinaryStruct.java | 3 +-
.../objectinspector/TestCrossMapEqualComparer.java | 5 +-
.../TestSimpleMapEqualComparer.java | 5 +-
.../teradata/TestTeradataBinarySerdeForDate.java | 2 +-
.../TestTeradataBinarySerdeForDecimal.java | 2 +-
.../TestTeradataBinarySerdeForTimeStamp.java | 6 +-
.../teradata/TestTeradataBinarySerdeGeneral.java | 2 +-
.../hive/service/cli/operation/SQLOperation.java | 2 +-
.../hive/streaming/StrictDelimitedInputWriter.java | 3 +-
.../apache/hive/streaming/StrictJsonWriter.java | 3 +-
.../apache/hive/streaming/StrictRegexWriter.java | 2 +-
131 files changed, 891 insertions(+), 1107 deletions(-)
delete mode 100644 serde/src/java/org/apache/hadoop/hive/serde2/AbstractDeserializer.java
delete mode 100644 serde/src/java/org/apache/hadoop/hive/serde2/AbstractSerializer.java
copy serde/src/java/org/apache/hadoop/hive/serde2/{SerDeStatsStruct.java => SerDe.java} (78%)