You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/10/13 00:15:58 UTC
[19/50] [abbrv] hive git commit: HIVE-14671 : merge master into
hive-14535 (Wei Zheng)
HIVE-14671 : merge master into hive-14535 (Wei Zheng)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/42a38577
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/42a38577
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/42a38577
Branch: refs/heads/master
Commit: 42a38577bc9d242bed040c503b0d1d46f74e0301
Parents: 81853c1 b82d38a
Author: Wei Zheng <we...@apache.org>
Authored: Wed Sep 6 21:24:02 2017 -0700
Committer: Wei Zheng <we...@apache.org>
Committed: Wed Sep 6 21:24:02 2017 -0700
----------------------------------------------------------------------
.gitignore | 1 +
LICENSE | 2 +-
.../accumulo/AccumuloConnectionParameters.java | 57 +-
.../hive/accumulo/AccumuloStorageHandler.java | 77 +-
.../hive/accumulo/HiveAccumuloHelper.java | 396 +-
.../org/apache/hadoop/hive/accumulo/Utils.java | 3 +-
.../mr/HiveAccumuloTableInputFormat.java | 244 +-
.../mr/HiveAccumuloTableOutputFormat.java | 84 +-
.../serde/CompositeAccumuloRowIdFactory.java | 3 +-
.../serde/DefaultAccumuloRowIdFactory.java | 5 +-
.../accumulo/TestAccumuloStorageHandler.java | 6 +-
.../hive/accumulo/TestHiveAccumuloHelper.java | 184 +-
.../mr/TestHiveAccumuloTableInputFormat.java | 37 +-
.../mr/TestHiveAccumuloTableOutputFormat.java | 29 +-
.../positive/accumulo_predicate_pushdown.q.out | 3 +-
.../results/positive/accumulo_queries.q.out | 2 +-
.../java/org/apache/hive/beeline/BeeLine.java | 4 +-
.../org/apache/hive/beeline/BeeLineOpts.java | 9 +
.../java/org/apache/hive/beeline/Commands.java | 32 +-
.../org/apache/hive/beeline/HiveSchemaTool.java | 58 +-
.../src/java/org/apache/hive/beeline/Rows.java | 21 +-
beeline/src/main/resources/BeeLine.properties | 1 +
.../apache/hive/beeline/TestBufferedRows.java | 2 +-
.../org/apache/hive/beeline/TestCommands.java | 29 +-
.../hive/beeline/TestIncrementalRows.java | 136 +
.../TestIncrementalRowsWithNormalization.java | 90 -
.../hive/beeline/TestTableOutputFormat.java | 2 +-
bin/ext/hbaseimport.sh | 27 -
bin/ext/hbaseschematool.sh | 27 -
bin/ext/metastore.sh | 2 +-
binary-package-licenses/org.json-LICENSE | 22 -
.../org/apache/hadoop/hive/cli/CliDriver.java | 10 +-
common/pom.xml | 8 +-
.../apache/hadoop/hive/common/FileUtils.java | 80 +-
.../org/apache/hadoop/hive/common/LogUtils.java | 41 +
.../hadoop/hive/common/jsonexplain/Vertex.java | 2 +-
.../common/jsonexplain/tez/TezJsonParser.java | 2 +
.../common/metrics/common/MetricsConstant.java | 14 -
.../common/ndv/NumDistinctValueEstimator.java | 51 +
.../ndv/NumDistinctValueEstimatorFactory.java | 74 +
.../hadoop/hive/common/ndv/fm/FMSketch.java | 359 +
.../hive/common/ndv/fm/FMSketchUtils.java | 132 +
.../hive/common/ndv/hll/HLLConstants.java | 929 +
.../hive/common/ndv/hll/HLLDenseRegister.java | 192 +
.../hadoop/hive/common/ndv/hll/HLLRegister.java | 50 +
.../hive/common/ndv/hll/HLLSparseRegister.java | 260 +
.../hadoop/hive/common/ndv/hll/HyperLogLog.java | 634 +
.../hive/common/ndv/hll/HyperLogLogUtils.java | 392 +
.../hadoop/hive/common/type/TimestampTZ.java | 122 +-
.../hive/common/type/TimestampTZUtil.java | 150 +
.../org/apache/hadoop/hive/conf/Constants.java | 2 +
.../org/apache/hadoop/hive/conf/HiveConf.java | 259 +-
.../apache/hadoop/hive/conf/HiveConfUtil.java | 20 +-
.../hive/common/util/HiveStringUtils.java | 92 +-
.../java/org/apache/hive/http/HttpServer.java | 1 +
.../java/org/apache/hive/http/StackServlet.java | 2 +-
.../src/main/resources/hive-log4j2.properties | 8 +-
.../hadoop/hive/common/TestFileUtils.java | 17 +-
.../ndv/fm/TestFMSketchSerialization.java | 98 +
.../hive/common/ndv/hll/TestHLLNoBias.java | 114 +
.../common/ndv/hll/TestHLLSerialization.java | 267 +
.../hive/common/ndv/hll/TestHyperLogLog.java | 227 +
.../common/ndv/hll/TestHyperLogLogDense.java | 82 +
.../common/ndv/hll/TestHyperLogLogSparse.java | 81 +
.../common/ndv/hll/TestSparseEncodeHash.java | 56 +
.../hive/common/type/TestTimestampTZ.java | 63 +-
.../apache/hadoop/hive/conf/TestHiveConf.java | 11 +
.../hive/conf/TestHiveConfRestrictList.java | 12 +-
.../hadoop/hive/conf/TestHiveConfUtil.java | 68 +
.../hive/common/util/TestHiveStringUtils.java | 51 +
.../clientpositive/udf_row_sequence.q.out | 6 +-
data/conf/hive-log4j2.properties | 11 +-
data/conf/hive-site.xml | 4 +
data/conf/llap/hive-site.xml | 9 +
data/conf/spark/standalone/hive-site.xml | 17 +-
data/conf/spark/yarn-client/hive-site.xml | 10 +
data/conf/tez/hive-site.xml | 10 +
data/files/having_data.txt | 8 +
data/files/impala_int96_timestamp.parq | Bin 241 -> 0 bytes
data/scripts/input20_script.py | 18 +-
dev-support/checkstyle_YETUS-484.sh | 406 +
dev-support/findbugs_YETUS-471.sh | 488 +
dev-support/hive-personality.sh | 100 +
dev-support/maven_YETUS-506.sh | 687 +
dev-support/smart-apply-patch.sh | 18 +
dev-support/test-patch.sh | 18 +
dev-support/yetus-wrapper.sh | 185 +
druid-handler/pom.xml | 4 +
.../hadoop/hive/druid/DruidStorageHandler.java | 189 +-
.../hive/druid/DruidStorageHandlerUtils.java | 378 +-
.../hadoop/hive/druid/io/DruidOutputFormat.java | 21 +-
.../hive/druid/security/DruidKerberosUtil.java | 126 +
.../hive/druid/security/KerberosHttpClient.java | 163 +
.../druid/security/ResponseCookieHandler.java | 92 +
.../RetryIfUnauthorizedResponseHandler.java | 104 +
.../druid/security/RetryResponseHolder.java | 46 +
.../serde/DruidGroupByQueryRecordReader.java | 44 +-
.../hadoop/hive/druid/serde/DruidSerDe.java | 42 +-
.../hive/druid/serde/DruidSerDeUtils.java | 26 +-
.../hadoop/hive/druid/TestDruidSerDe.java | 50 +-
.../hive/druid/TestDruidStorageHandler.java | 384 +-
.../hive/ql/io/TestDruidRecordWriter.java | 6 +-
errata.txt | 1 +
.../results/positive/hbase_ppd_key_range.q.out | 3 +-
.../test/results/positive/hbase_queries.q.out | 2 +-
.../test/results/positive/ppd_key_ranges.q.out | 34 +-
.../cli/SemanticAnalysis/HCatAuthUtil.java | 3 +-
.../mapreduce/FileRecordWriterContainer.java | 7 +-
.../hcatalog/mapreduce/HCatBaseInputFormat.java | 3 +
.../mapreduce/HCatBaseOutputFormat.java | 15 +-
.../hive/hcatalog/mapreduce/SpecialCases.java | 27 +
.../apache/hive/hcatalog/cli/TestPermsGrp.java | 4 +-
.../mapreduce/TestHCatOutputFormat.java | 43 +-
.../mapreduce/TestHCatPartitionPublish.java | 6 +-
.../apache/hive/hcatalog/pig/HCatLoader.java | 2 +-
.../pig/TestHCatLoaderComplexSchema.java | 3 -
.../hcatalog/pig/TestHCatLoaderEncryption.java | 9 +-
.../hive/hcatalog/pig/TestHCatStorerMulti.java | 10 +-
.../hcatalog/pig/TestParquetHCatLoader.java | 49 -
.../hcatalog/pig/TestParquetHCatStorer.java | 167 -
.../listener/DbNotificationListener.java | 101 +-
.../MetaStoreEventListenerConstants.java | 33 -
.../hcatalog/messaging/AddPartitionMessage.java | 2 +
.../messaging/AlterPartitionMessage.java | 2 +
.../hcatalog/messaging/AlterTableMessage.java | 1 +
.../hcatalog/messaging/CreateTableMessage.java | 2 +
.../messaging/DropPartitionMessage.java | 1 +
.../hcatalog/messaging/DropTableMessage.java | 1 +
.../hive/hcatalog/messaging/InsertMessage.java | 1 +
.../hive/hcatalog/messaging/MessageFactory.java | 12 +
.../messaging/json/JSONAddPartitionMessage.java | 15 +-
.../json/JSONAlterPartitionMessage.java | 19 +-
.../messaging/json/JSONAlterTableMessage.java | 18 +-
.../messaging/json/JSONCreateTableMessage.java | 16 +-
.../json/JSONDropPartitionMessage.java | 15 +-
.../messaging/json/JSONDropTableMessage.java | 11 +-
.../messaging/json/JSONInsertMessage.java | 14 +-
.../messaging/json/JSONMessageFactory.java | 28 +-
.../listener/TestNotificationListener.java | 7 +
hcatalog/src/test/e2e/hcatalog/tests/hcat.conf | 2 +-
.../streaming/AbstractRecordWriter.java | 44 +-
.../hive/hcatalog/streaming/HiveEndPoint.java | 4 +-
.../mutate/worker/BucketIdResolverImpl.java | 6 +-
.../mutate/worker/MutatorCoordinator.java | 7 +-
.../streaming/mutate/worker/MutatorImpl.java | 16 +-
.../apache/hive/hcatalog/streaming/package.html | 21 +-
.../hive/hcatalog/streaming/TestStreaming.java | 229 +-
.../streaming/mutate/StreamingAssert.java | 46 +-
.../streaming/mutate/TestMutations.java | 56 +-
.../mutate/worker/TestBucketIdResolverImpl.java | 6 +-
.../mutate/worker/TestMutatorImpl.java | 2 +-
.../hive/hcatalog/api/TestHCatClient.java | 118 +-
.../api/TestHCatClientNotification.java | 5 +
.../listener/DummyRawStoreFailEvent.java | 27 +-
.../listener/TestDbNotificationListener.java | 19 +-
.../src/test/queries/clientpositive/having.q | 12 +
...rt_overwrite_dynamic_partitions_merge_move.q | 37 +
...rt_overwrite_dynamic_partitions_merge_only.q | 37 +
...ert_overwrite_dynamic_partitions_move_only.q | 37 +
.../test/results/clientpositive/having.q.out | 59 +
.../insert_blobstore_to_blobstore.q.out | 6 +
.../insert_empty_into_blobstore.q.out | 3 +
.../clientpositive/insert_into_table.q.out | 2 +
...verwrite_dynamic_partitions_merge_move.q.out | 138 +
...verwrite_dynamic_partitions_merge_only.q.out | 128 +
...overwrite_dynamic_partitions_move_only.q.out | 158 +
.../clientpositive/insert_overwrite_table.q.out | 2 +
.../clientpositive/orc_format_nonpart.q.out | 6 +
.../clientpositive/orc_format_part.q.out | 16 +
.../orc_nonstd_partitions_loc.q.out | 24 +
.../clientpositive/rcfile_format_nonpart.q.out | 6 +
.../clientpositive/rcfile_format_part.q.out | 16 +
.../rcfile_nonstd_partitions_loc.q.out | 24 +
.../clientpositive/zero_rows_blobstore.q.out | 2 +
itests/hive-jmh/pom.xml | 6 +
.../benchmark/storage/ColumnarStorageBench.java | 3 +-
.../vectorization/mapjoin/AbstractMapJoin.java | 179 +
.../mapjoin/MapJoinMultiKeyBench.java | 313 +
.../mapjoin/MapJoinMultiKeyBenchBase.java | 68 +
.../mapjoin/MapJoinOneLongKeyBench.java | 313 +
.../mapjoin/MapJoinOneLongKeyBenchBase.java | 66 +
.../mapjoin/MapJoinOneStringKeyBench.java | 313 +
.../mapjoin/MapJoinOneStringKeyBenchBase.java | 66 +
.../hive/minikdc/TestHs2HooksWithMiniKdc.java | 28 +-
.../security/TestHadoopAuthBridge23.java | 416 +
.../hive/thrift/TestHadoopAuthBridge23.java | 417 -
itests/hive-unit/pom.xml | 6 +
.../apache/hadoop/hive/hooks/TestHs2Hooks.java | 27 +-
.../AbstractTestAuthorizationApiAuthorizer.java | 4 +-
.../hadoop/hive/metastore/TestFilterHooks.java | 4 +-
.../hive/metastore/TestHiveMetaStore.java | 144 +-
.../metastore/TestHiveMetaStoreStatsMerge.java | 199 -
...TestHiveMetaStoreWithEnvironmentContext.java | 4 +-
.../metastore/TestMetaStoreAuthorization.java | 4 +-
.../TestMetaStoreEndFunctionListener.java | 5 +-
.../metastore/TestMetaStoreEventListener.java | 72 +-
.../TestMetaStoreEventListenerOnlyOnCommit.java | 4 +-
.../metastore/TestMetaStoreInitListener.java | 5 +-
.../metastore/TestMetaStoreListenersError.java | 6 +-
.../hive/metastore/TestMetaStoreMetrics.java | 82 +-
.../hive/metastore/TestRemoteHiveMetaStore.java | 4 +-
.../TestRemoteHiveMetaStoreIpAddress.java | 4 +-
.../hive/metastore/TestReplChangeManager.java | 37 +-
.../hive/metastore/TestRetryingHMSHandler.java | 4 +-
.../metastore/hbase/HBaseIntegrationTests.java | 112 -
.../TestHBaseAggrStatsCacheIntegration.java | 691 -
.../hive/metastore/hbase/TestHBaseImport.java | 775 -
.../hbase/TestHBaseMetastoreMetrics.java | 130 -
.../metastore/hbase/TestHBaseMetastoreSql.java | 223 -
.../metastore/hbase/TestHBaseSchemaTool.java | 582 -
.../metastore/hbase/TestHBaseSchemaTool2.java | 59 -
.../hbase/TestHBaseStoreIntegration.java | 1801 -
.../hbase/TestStorageDescriptorSharing.java | 191 -
.../apache/hadoop/hive/ql/TestAcidOnTez.java | 367 +-
.../hive/ql/TestAcidOnTezWithSplitUpdate.java | 28 -
...estDDLWithRemoteMetastoreSecondNamenode.java | 4 +-
.../hadoop/hive/ql/TestLocationQueries.java | 2 +-
.../hadoop/hive/ql/parse/TestExportImport.java | 100 +
.../hive/ql/parse/TestReplicationScenarios.java | 2772 +-
...TestReplicationScenariosAcrossInstances.java | 91 +-
.../hadoop/hive/ql/parse/WarehouseInstance.java | 89 +-
.../security/StorageBasedMetastoreTestBase.java | 5 +-
.../TestAuthorizationPreEventListener.java | 23 +-
.../TestClientSideAuthorizationProvider.java | 4 +-
.../TestMetastoreAuthorizationProvider.java | 4 +-
.../TestMultiAuthorizationPreEventListener.java | 4 +-
.../TestHiveAuthorizerCheckInvocation.java | 38 +
.../hive/ql/txn/compactor/TestCompactor.java | 4 +-
.../org/apache/hive/beeline/TestSchemaTool.java | 22 +-
.../apache/hive/jdbc/TestJdbcWithMiniHS2.java | 36 +-
.../hive/service/TestDFSErrorHandling.java | 152 +
.../operation/TestOperationLoggingLayout.java | 52 +
.../service/cli/session/TestQueryDisplay.java | 3 +-
itests/pom.xml | 2 +-
itests/qtest-accumulo/pom.xml | 3 +-
.../test/resources/testconfiguration.properties | 38 +-
.../hadoop/hive/accumulo/AccumuloQTestUtil.java | 2 +-
.../hive/cli/control/AbstractCliConfig.java | 4 +-
.../control/AbstractCoreBlobstoreCliDriver.java | 3 +-
.../hadoop/hive/cli/control/CliConfigs.java | 4 +-
.../hadoop/hive/cli/control/CoreCliDriver.java | 4 +-
.../hive/cli/control/CoreCompareCliDriver.java | 2 +-
.../hive/cli/control/CoreNegativeCliDriver.java | 2 +-
.../hive/cli/control/CorePerfCliDriver.java | 2 +-
.../hadoop/hive/hbase/HBaseQTestUtil.java | 2 +-
.../metastore/hbase/HBaseStoreTestUtil.java | 45 -
.../org/apache/hadoop/hive/ql/QTestUtil.java | 87 +-
.../hadoop/hive/ql/parse/CoreParseNegative.java | 3 +-
.../org/apache/hive/beeline/Parallelized.java | 9 +-
.../org/apache/hive/jdbc/miniHS2/MiniHS2.java | 4 +-
.../hive/storage/jdbc/JdbcRecordReader.java | 7 +-
.../org/apache/hive/storage/jdbc/JdbcSerDe.java | 18 +-
.../storage/jdbc/dao/JdbcRecordIterator.java | 8 +-
.../src/test/java/org/apache/TestSuite.java | 29 -
.../org/apache/hive/storage/jdbc/TestSuite.java | 29 +
.../dao/GenericJdbcDatabaseAccessorTest.java | 8 +-
jdbc/pom.xml | 2 +-
.../org/apache/hive/jdbc/HiveBaseResultSet.java | 6 +-
.../org/apache/hive/jdbc/HiveConnection.java | 5 +-
.../java/org/apache/hive/jdbc/JdbcColumn.java | 8 +-
.../hadoop/hive/llap/LlapBaseRecordReader.java | 103 +-
.../apache/hadoop/hive/llap/SubmitWorkInfo.java | 16 +-
.../ext/LlapTaskUmbilicalExternalClient.java | 504 +-
.../apache/hadoop/hive/llap/io/api/LlapIo.java | 4 +-
.../hive/llap/registry/ServiceInstance.java | 2 +-
.../hive/llap/tez/LlapProtocolClientProxy.java | 423 +-
.../helpers/LlapTaskUmbilicalServer.java | 44 +-
.../hadoop/hive/llap/TestAsyncPbRpcProxy.java | 145 +
.../tez/TestLlapDaemonProtocolClientProxy.java | 144 -
.../daemon/rpc/LlapDaemonProtocolProtos.java | 1854 +-
.../hadoop/hive/llap/AsyncPbRpcProxy.java | 435 +
.../hive/llap/impl/LlapProtocolClientImpl.java | 20 +-
.../hadoop/hive/llap/io/ChunkedInputStream.java | 16 +-
.../hive/llap/io/ChunkedOutputStream.java | 9 +-
.../src/protobuf/LlapDaemonProtocol.proto | 16 +-
.../hive/llap/io/TestChunkedInputStream.java | 6 +-
.../hadoop/hive/llap/LlapBaseInputFormat.java | 2 -
llap-server/bin/llapDaemon.sh | 3 +
llap-server/pom.xml | 7 +-
.../hadoop/hive/llap/cache/BuddyAllocator.java | 1496 +-
.../hive/llap/cache/EvictionDispatcher.java | 23 +-
.../hive/llap/cache/LlapAllocatorBuffer.java | 414 +
.../hive/llap/cache/LlapCacheableBuffer.java | 6 +-
.../hadoop/hive/llap/cache/LlapDataBuffer.java | 119 +-
.../hive/llap/cache/LowLevelCacheImpl.java | 70 +-
.../llap/cache/LowLevelCacheMemoryManager.java | 7 -
.../hive/llap/cache/LowLevelCachePolicy.java | 2 -
.../llap/cache/LowLevelFifoCachePolicy.java | 16 +-
.../llap/cache/LowLevelLrfuCachePolicy.java | 95 +-
.../hadoop/hive/llap/cache/MemoryManager.java | 2 -
.../hive/llap/cache/SerDeLowLevelCacheImpl.java | 115 +-
.../hadoop/hive/llap/cache/SimpleAllocator.java | 22 +-
.../hive/llap/cache/SimpleBufferManager.java | 12 +-
.../hadoop/hive/llap/cli/LlapServiceDriver.java | 6 +-
.../configuration/LlapDaemonConfiguration.java | 9 +-
.../hive/llap/daemon/ContainerRunner.java | 7 +-
.../llap/daemon/impl/ContainerRunnerImpl.java | 26 +-
.../impl/EvictingPriorityBlockingQueue.java | 29 +-
.../hive/llap/daemon/impl/LlapDaemon.java | 8 +
.../daemon/impl/LlapProtocolServerImpl.java | 12 +
.../llap/daemon/impl/QueryFragmentInfo.java | 24 +-
.../hadoop/hive/llap/daemon/impl/QueryInfo.java | 7 +-
.../hadoop/hive/llap/daemon/impl/Scheduler.java | 6 +-
.../impl/StaticPermanentFunctionChecker.java | 3 +-
.../llap/daemon/impl/TaskExecutorService.java | 451 +-
.../llap/daemon/impl/TaskRunnerCallable.java | 22 +-
.../comparator/FirstInFirstOutComparator.java | 14 +-
.../comparator/LlapQueueComparatorBase.java | 48 +
.../comparator/ShortestJobFirstComparator.java | 17 +-
.../daemon/services/impl/LlapWebServices.java | 1 +
.../impl/SystemConfigurationServlet.java | 196 +
.../hive/llap/io/api/impl/LlapInputFormat.java | 63 +-
.../hive/llap/io/api/impl/LlapIoImpl.java | 108 +-
.../hive/llap/io/api/impl/LlapRecordReader.java | 88 +-
.../llap/io/decode/EncodedDataConsumer.java | 1 +
.../io/decode/GenericColumnVectorProducer.java | 9 +-
.../llap/io/decode/OrcColumnVectorProducer.java | 15 +-
.../llap/io/decode/OrcEncodedDataConsumer.java | 12 +
.../llap/io/encoded/OrcEncodedDataReader.java | 122 +-
.../llap/io/encoded/SerDeEncodedDataReader.java | 75 +-
.../io/encoded/VectorDeserializeOrcWriter.java | 3 +
.../llap/io/metadata/OrcFileEstimateErrors.java | 4 +-
.../hive/llap/io/metadata/OrcFileMetadata.java | 4 +-
.../llap/io/metadata/OrcStripeMetadata.java | 4 +-
.../io/metadata/ParquetMetadataCacheImpl.java | 353 +
.../hive/llap/metrics/LlapDaemonJvmInfo.java | 3 +-
.../hive/llap/metrics/LlapDaemonJvmMetrics.java | 7 +-
.../llap/shufflehandler/FadvisedFileRegion.java | 14 +-
.../llap/shufflehandler/ShuffleHandler.java | 23 +-
llap-server/src/main/resources/templates.py | 2 +-
.../hive/llap/cache/TestBuddyAllocator.java | 73 +-
.../cache/TestBuddyAllocatorForceEvict.java | 470 +
.../hive/llap/cache/TestLowLevelCacheImpl.java | 29 +-
.../llap/cache/TestLowLevelLrfuCachePolicy.java | 56 -
.../hive/llap/cache/TestOrcMetadataCache.java | 12 -
.../daemon/impl/TaskExecutorTestHelpers.java | 97 +-
.../impl/TestEvictingPriorityBlockingQueue.java | 12 +-
.../daemon/impl/TestTaskExecutorService.java | 165 +-
.../TestFirstInFirstOutComparator.java | 36 +-
.../TestShortestJobFirstComparator.java | 35 +-
metastore/if/hive_metastore.thrift | 1593 -
metastore/pom.xml | 90 +-
.../upgrade/derby/022-HIVE-11107.derby.sql | 2 +-
.../upgrade/derby/043-HIVE-16922.derby.sql | 3 +
.../upgrade/derby/044-HIVE-16997.derby.sql | 2 +
.../upgrade/derby/hive-schema-3.0.0.derby.sql | 2 +-
.../derby/upgrade-2.3.0-to-3.0.0.derby.sql | 2 +
.../upgrade/hive/hive-schema-3.0.0.hive.sql | 24 +
.../upgrade/mssql/028-HIVE-16922.mssql.sql | 3 +
.../upgrade/mssql/029-HIVE-16997.mssql.sql | 2 +
.../upgrade/mssql/hive-schema-3.0.0.mssql.sql | 2 +
.../mssql/upgrade-2.3.0-to-3.0.0.mssql.sql | 2 +
.../upgrade/mysql/043-HIVE-16922.mysql.sql | 3 +
.../upgrade/mysql/044-HIVE-16997.mysql.sql | 2 +
.../upgrade/mysql/hive-schema-3.0.0.mysql.sql | 4 +-
.../mysql/upgrade-2.3.0-to-3.0.0.mysql.sql | 2 +
.../upgrade/oracle/043-HIVE-16922.oracle.sql | 3 +
.../upgrade/oracle/044-HIVE-16997.oracle.sql | 2 +
.../upgrade/oracle/hive-schema-3.0.0.oracle.sql | 2 +
.../oracle/upgrade-2.3.0-to-3.0.0.oracle.sql | 2 +
.../postgres/042-HIVE-16922.postgres.sql | 3 +
.../postgres/043-HIVE-16997.postgres.sql | 2 +
.../postgres/hive-schema-3.0.0.postgres.sql | 2 +
.../upgrade-2.3.0-to-3.0.0.postgres.sql | 2 +
.../metastore/hbase/HbaseMetastoreProto.java | 46709 ----
.../gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 73240 ------
.../gen/thrift/gen-cpp/ThriftHiveMetastore.h | 23202 --
.../ThriftHiveMetastore_server.skeleton.cpp | 834 -
.../thrift/gen-cpp/hive_metastore_constants.cpp | 65 -
.../thrift/gen-cpp/hive_metastore_constants.h | 48 -
.../gen/thrift/gen-cpp/hive_metastore_types.cpp | 21453 --
.../gen/thrift/gen-cpp/hive_metastore_types.h | 8861 -
.../hive/metastore/api/AbortTxnRequest.java | 387 -
.../hive/metastore/api/AbortTxnsRequest.java | 438 -
.../metastore/api/AddDynamicPartitions.java | 864 -
.../metastore/api/AddForeignKeyRequest.java | 443 -
.../api/AddNotNullConstraintRequest.java | 443 -
.../metastore/api/AddPartitionsRequest.java | 849 -
.../hive/metastore/api/AddPartitionsResult.java | 447 -
.../metastore/api/AddPrimaryKeyRequest.java | 443 -
.../api/AddUniqueConstraintRequest.java | 443 -
.../hadoop/hive/metastore/api/AggrStats.java | 542 -
.../metastore/api/AlreadyExistsException.java | 395 -
.../metastore/api/BinaryColumnStatsData.java | 687 -
.../metastore/api/BooleanColumnStatsData.java | 687 -
.../metastore/api/CacheFileMetadataRequest.java | 703 -
.../metastore/api/CacheFileMetadataResult.java | 387 -
.../hive/metastore/api/CheckLockRequest.java | 589 -
.../metastore/api/ClearFileMetadataRequest.java | 438 -
.../metastore/api/ClearFileMetadataResult.java | 283 -
.../hive/metastore/api/ClientCapabilities.java | 441 -
.../hive/metastore/api/ClientCapability.java | 45 -
.../hive/metastore/api/ColumnStatistics.java | 549 -
.../metastore/api/ColumnStatisticsData.java | 675 -
.../metastore/api/ColumnStatisticsDesc.java | 798 -
.../hive/metastore/api/ColumnStatisticsObj.java | 593 -
.../hive/metastore/api/CommitTxnRequest.java | 387 -
.../hive/metastore/api/CompactionRequest.java | 977 -
.../hive/metastore/api/CompactionResponse.java | 583 -
.../hive/metastore/api/CompactionType.java | 45 -
.../api/ConfigValSecurityException.java | 395 -
.../api/CurrentNotificationEventId.java | 387 -
.../hive/metastore/api/DataOperationType.java | 57 -
.../hadoop/hive/metastore/api/Database.java | 1095 -
.../apache/hadoop/hive/metastore/api/Date.java | 387 -
.../hive/metastore/api/DateColumnStatsData.java | 814 -
.../hadoop/hive/metastore/api/Decimal.java | 497 -
.../metastore/api/DecimalColumnStatsData.java | 814 -
.../metastore/api/DoubleColumnStatsData.java | 790 -
.../metastore/api/DropConstraintRequest.java | 591 -
.../hive/metastore/api/DropPartitionsExpr.java | 505 -
.../metastore/api/DropPartitionsRequest.java | 1112 -
.../metastore/api/DropPartitionsResult.java | 447 -
.../hive/metastore/api/EnvironmentContext.java | 447 -
.../hive/metastore/api/EventRequestType.java | 48 -
.../hadoop/hive/metastore/api/FieldSchema.java | 603 -
.../metastore/api/FileMetadataExprType.java | 42 -
.../hive/metastore/api/FireEventRequest.java | 861 -
.../metastore/api/FireEventRequestData.java | 309 -
.../hive/metastore/api/FireEventResponse.java | 283 -
.../hive/metastore/api/ForeignKeysRequest.java | 707 -
.../hive/metastore/api/ForeignKeysResponse.java | 443 -
.../hadoop/hive/metastore/api/Function.java | 1199 -
.../hadoop/hive/metastore/api/FunctionType.java | 42 -
.../metastore/api/GetAllFunctionsResponse.java | 447 -
.../api/GetFileMetadataByExprRequest.java | 773 -
.../api/GetFileMetadataByExprResult.java | 553 -
.../metastore/api/GetFileMetadataRequest.java | 438 -
.../metastore/api/GetFileMetadataResult.java | 540 -
.../metastore/api/GetOpenTxnsInfoResponse.java | 542 -
.../hive/metastore/api/GetOpenTxnsResponse.java | 750 -
.../api/GetPrincipalsInRoleRequest.java | 389 -
.../api/GetPrincipalsInRoleResponse.java | 443 -
.../api/GetRoleGrantsForPrincipalRequest.java | 502 -
.../api/GetRoleGrantsForPrincipalResponse.java | 443 -
.../hive/metastore/api/GetTableRequest.java | 605 -
.../hive/metastore/api/GetTableResult.java | 394 -
.../hive/metastore/api/GetTablesRequest.java | 659 -
.../hive/metastore/api/GetTablesResult.java | 443 -
.../api/GrantRevokePrivilegeRequest.java | 620 -
.../api/GrantRevokePrivilegeResponse.java | 390 -
.../metastore/api/GrantRevokeRoleRequest.java | 1059 -
.../metastore/api/GrantRevokeRoleResponse.java | 390 -
.../hive/metastore/api/GrantRevokeType.java | 45 -
.../hive/metastore/api/HeartbeatRequest.java | 489 -
.../metastore/api/HeartbeatTxnRangeRequest.java | 482 -
.../api/HeartbeatTxnRangeResponse.java | 588 -
.../hive/metastore/api/HiveObjectPrivilege.java | 729 -
.../hive/metastore/api/HiveObjectRef.java | 872 -
.../hive/metastore/api/HiveObjectType.java | 54 -
.../apache/hadoop/hive/metastore/api/Index.java | 1374 -
.../api/IndexAlreadyExistsException.java | 395 -
.../metastore/api/InsertEventRequestData.java | 700 -
.../metastore/api/InvalidInputException.java | 395 -
.../metastore/api/InvalidObjectException.java | 395 -
.../api/InvalidOperationException.java | 395 -
.../api/InvalidPartitionException.java | 395 -
.../hive/metastore/api/LockComponent.java | 1158 -
.../hadoop/hive/metastore/api/LockLevel.java | 48 -
.../hadoop/hive/metastore/api/LockRequest.java | 861 -
.../hadoop/hive/metastore/api/LockResponse.java | 500 -
.../hadoop/hive/metastore/api/LockState.java | 51 -
.../hadoop/hive/metastore/api/LockType.java | 48 -
.../hive/metastore/api/LongColumnStatsData.java | 790 -
.../hive/metastore/api/MetaException.java | 395 -
.../hive/metastore/api/MetadataPpdResult.java | 517 -
.../hive/metastore/api/NoSuchLockException.java | 395 -
.../metastore/api/NoSuchObjectException.java | 395 -
.../hive/metastore/api/NoSuchTxnException.java | 395 -
.../api/NotNullConstraintsRequest.java | 490 -
.../api/NotNullConstraintsResponse.java | 443 -
.../hive/metastore/api/NotificationEvent.java | 1006 -
.../metastore/api/NotificationEventRequest.java | 490 -
.../api/NotificationEventResponse.java | 443 -
.../hive/metastore/api/OpenTxnRequest.java | 702 -
.../hive/metastore/api/OpenTxnsResponse.java | 438 -
.../apache/hadoop/hive/metastore/api/Order.java | 497 -
.../hadoop/hive/metastore/api/Partition.java | 1229 -
.../hive/metastore/api/PartitionEventType.java | 42 -
.../api/PartitionListComposingSpec.java | 449 -
.../hive/metastore/api/PartitionSpec.java | 826 -
.../api/PartitionSpecWithSharedSD.java | 558 -
.../hive/metastore/api/PartitionWithoutSD.java | 1016 -
.../metastore/api/PartitionsByExprRequest.java | 815 -
.../metastore/api/PartitionsByExprResult.java | 542 -
.../metastore/api/PartitionsStatsRequest.java | 790 -
.../metastore/api/PartitionsStatsResult.java | 490 -
.../hive/metastore/api/PrimaryKeysRequest.java | 490 -
.../hive/metastore/api/PrimaryKeysResponse.java | 443 -
.../metastore/api/PrincipalPrivilegeSet.java | 906 -
.../hive/metastore/api/PrincipalType.java | 48 -
.../hadoop/hive/metastore/api/PrivilegeBag.java | 449 -
.../hive/metastore/api/PrivilegeGrantInfo.java | 815 -
.../metastore/api/PutFileMetadataRequest.java | 710 -
.../metastore/api/PutFileMetadataResult.java | 283 -
.../hive/metastore/api/RequestPartsSpec.java | 438 -
.../hadoop/hive/metastore/api/ResourceType.java | 48 -
.../hadoop/hive/metastore/api/ResourceUri.java | 511 -
.../apache/hadoop/hive/metastore/api/Role.java | 601 -
.../hive/metastore/api/RolePrincipalGrant.java | 1035 -
.../hive/metastore/api/SQLForeignKey.java | 1715 -
.../metastore/api/SQLNotNullConstraint.java | 1005 -
.../hive/metastore/api/SQLPrimaryKey.java | 1103 -
.../hive/metastore/api/SQLUniqueConstraint.java | 1103 -
.../hadoop/hive/metastore/api/Schema.java | 605 -
.../hadoop/hive/metastore/api/SerDeInfo.java | 655 -
.../api/SetPartitionsStatsRequest.java | 550 -
.../hive/metastore/api/ShowCompactRequest.java | 283 -
.../hive/metastore/api/ShowCompactResponse.java | 443 -
.../api/ShowCompactResponseElement.java | 1641 -
.../hive/metastore/api/ShowLocksRequest.java | 710 -
.../hive/metastore/api/ShowLocksResponse.java | 449 -
.../metastore/api/ShowLocksResponseElement.java | 1929 -
.../hadoop/hive/metastore/api/SkewedInfo.java | 834 -
.../hive/metastore/api/StorageDescriptor.java | 1748 -
.../metastore/api/StringColumnStatsData.java | 782 -
.../apache/hadoop/hive/metastore/api/Table.java | 1948 -
.../hadoop/hive/metastore/api/TableMeta.java | 701 -
.../hive/metastore/api/TableStatsRequest.java | 640 -
.../hive/metastore/api/TableStatsResult.java | 443 -
.../hive/metastore/api/ThriftHiveMetastore.java | 186370 ---------------
.../hive/metastore/api/TxnAbortedException.java | 395 -
.../hadoop/hive/metastore/api/TxnInfo.java | 1220 -
.../hive/metastore/api/TxnOpenException.java | 395 -
.../hadoop/hive/metastore/api/TxnState.java | 48 -
.../apache/hadoop/hive/metastore/api/Type.java | 768 -
.../metastore/api/UniqueConstraintsRequest.java | 490 -
.../api/UniqueConstraintsResponse.java | 443 -
.../hive/metastore/api/UnknownDBException.java | 395 -
.../api/UnknownPartitionException.java | 395 -
.../metastore/api/UnknownTableException.java | 395 -
.../hive/metastore/api/UnlockRequest.java | 387 -
.../hadoop/hive/metastore/api/Version.java | 499 -
.../metastore/api/hive_metastoreConstants.java | 87 -
.../gen-php/metastore/ThriftHiveMetastore.php | 46667 ----
.../src/gen/thrift/gen-php/metastore/Types.php | 20941 --
.../hive_metastore/ThriftHiveMetastore-remote | 1291 -
.../hive_metastore/ThriftHiveMetastore.py | 37904 ----
.../thrift/gen-py/hive_metastore/__init__.py | 1 -
.../thrift/gen-py/hive_metastore/constants.py | 35 -
.../gen/thrift/gen-py/hive_metastore/ttypes.py | 14886 --
.../thrift/gen-rb/hive_metastore_constants.rb | 57 -
.../gen/thrift/gen-rb/hive_metastore_types.rb | 3444 -
.../gen/thrift/gen-rb/thrift_hive_metastore.rb | 10557 -
.../hadoop/hive/metastore/DatabaseProduct.java | 2 +-
.../apache/hadoop/hive/metastore/Deadline.java | 4 +-
.../hive/metastore/FileMetadataManager.java | 7 +-
.../hive/metastore/HMSMetricsListener.java | 47 +-
.../hadoop/hive/metastore/HiveAlterHandler.java | 22 +-
.../hadoop/hive/metastore/HiveMetaHook.java | 4 +
.../hadoop/hive/metastore/HiveMetaStore.java | 606 +-
.../hive/metastore/HiveMetaStoreClient.java | 78 +-
.../hadoop/hive/metastore/IMetaStoreClient.java | 89 +-
.../hive/metastore/IMetaStoreSchemaInfo.java | 2 +-
.../hive/metastore/MetaStoreDirectSql.java | 464 +-
.../hive/metastore/MetaStoreEventListener.java | 45 +-
.../MetaStoreEventListenerConstants.java | 41 +
.../hive/metastore/MetaStoreFilterHook.java | 5 +-
.../metastore/MetaStoreListenerNotifier.java | 52 +-
.../metastore/MetaStorePreEventListener.java | 5 +-
.../hive/metastore/MetaStoreSchemaInfo.java | 4 +-
.../hadoop/hive/metastore/MetaStoreThread.java | 2 +-
.../hadoop/hive/metastore/MetaStoreUtils.java | 314 +-
.../metastore/NumDistinctValueEstimator.java | 367 -
.../hadoop/hive/metastore/ObjectStore.java | 178 +-
.../hive/metastore/PartFilterExprUtil.java | 2 +-
.../apache/hadoop/hive/metastore/RawStore.java | 23 +-
.../hive/metastore/ReplChangeManager.java | 153 +-
.../hive/metastore/RetryingHMSHandler.java | 4 +-
.../hive/metastore/StatObjectConverter.java | 87 +-
.../hive/metastore/TUGIBasedProcessor.java | 2 +-
.../TransactionalMetaStoreEventListener.java | 39 +
.../TransactionalValidationListener.java | 44 +-
.../apache/hadoop/hive/metastore/Warehouse.java | 21 +-
.../hive/metastore/cache/CachedStore.java | 169 +-
.../hive/metastore/cache/SharedCache.java | 10 +-
.../aggr/BinaryColumnStatsAggregator.java | 64 +
.../aggr/BooleanColumnStatsAggregator.java | 65 +
.../columnstats/aggr/ColumnStatsAggregator.java | 33 +
.../aggr/ColumnStatsAggregatorFactory.java | 113 +
.../aggr/DateColumnStatsAggregator.java | 362 +
.../aggr/DecimalColumnStatsAggregator.java | 375 +
.../aggr/DoubleColumnStatsAggregator.java | 349 +
.../aggr/IExtrapolatePartStatus.java | 47 +
.../aggr/LongColumnStatsAggregator.java | 348 +
.../aggr/StringColumnStatsAggregator.java | 305 +
.../cache/DateColumnStatsDataInspector.java | 124 +
.../cache/DecimalColumnStatsDataInspector.java | 124 +
.../cache/DoubleColumnStatsDataInspector.java | 124 +
.../cache/LongColumnStatsDataInspector.java | 124 +
.../cache/StringColumnStatsDataInspector.java | 125 +
.../merge/BinaryColumnStatsMerger.java | 35 +
.../merge/BooleanColumnStatsMerger.java | 35 +
.../columnstats/merge/ColumnStatsMerger.java | 31 +
.../merge/ColumnStatsMergerFactory.java | 120 +
.../merge/DateColumnStatsMerger.java | 59 +
.../merge/DecimalColumnStatsMerger.java | 61 +
.../merge/DoubleColumnStatsMerger.java | 54 +
.../merge/LongColumnStatsMerger.java | 54 +
.../merge/StringColumnStatsMerger.java | 54 +
.../datasource/BoneCPDataSourceProvider.java | 95 +
.../datasource/DataSourceProvider.java | 79 +
.../datasource/DataSourceProviderFactory.java | 47 +
.../datasource/HikariCPDataSourceProvider.java | 97 +
.../hive/metastore/datasource/package-info.java | 23 +
.../metastore/events/AddForeignKeyEvent.java | 37 +
.../hive/metastore/events/AddIndexEvent.java | 4 +
.../events/AddNotNullConstraintEvent.java | 37 +
.../metastore/events/AddPartitionEvent.java | 4 +
.../metastore/events/AddPrimaryKeyEvent.java | 38 +
.../events/AddUniqueConstraintEvent.java | 37 +
.../hive/metastore/events/AlterIndexEvent.java | 4 +
.../metastore/events/AlterPartitionEvent.java | 4 +
.../hive/metastore/events/AlterTableEvent.java | 4 +
.../metastore/events/ConfigChangeEvent.java | 4 +
.../metastore/events/CreateDatabaseEvent.java | 4 +
.../metastore/events/CreateFunctionEvent.java | 4 +
.../hive/metastore/events/CreateTableEvent.java | 4 +
.../metastore/events/DropConstraintEvent.java | 47 +
.../metastore/events/DropDatabaseEvent.java | 4 +
.../metastore/events/DropFunctionEvent.java | 4 +
.../hive/metastore/events/DropIndexEvent.java | 4 +
.../metastore/events/DropPartitionEvent.java | 4 +
.../hive/metastore/events/DropTableEvent.java | 4 +
.../hive/metastore/events/InsertEvent.java | 6 +-
.../hive/metastore/events/ListenerEvent.java | 5 +-
.../events/LoadPartitionDoneEvent.java | 4 +
.../hive/metastore/events/PreAddIndexEvent.java | 4 +
.../metastore/events/PreAddPartitionEvent.java | 4 +
.../metastore/events/PreAlterDatabaseEvent.java | 47 +
.../metastore/events/PreAlterIndexEvent.java | 4 +
.../events/PreAlterPartitionEvent.java | 4 +
.../metastore/events/PreAlterTableEvent.java | 4 +
.../events/PreAuthorizationCallEvent.java | 4 +
.../events/PreCreateDatabaseEvent.java | 4 +
.../metastore/events/PreCreateTableEvent.java | 4 +
.../metastore/events/PreDropDatabaseEvent.java | 4 +
.../metastore/events/PreDropIndexEvent.java | 4 +
.../metastore/events/PreDropPartitionEvent.java | 4 +
.../metastore/events/PreDropTableEvent.java | 4 +
.../hive/metastore/events/PreEventContext.java | 8 +-
.../events/PreLoadPartitionDoneEvent.java | 4 +
.../metastore/events/PreReadDatabaseEvent.java | 4 +
.../metastore/events/PreReadTableEvent.java | 4 +
.../hbase/AggrStatsInvalidatorFilter.java | 121 -
.../hadoop/hive/metastore/hbase/Counter.java | 53 -
.../hive/metastore/hbase/HBaseConnection.java | 96 -
.../metastore/hbase/HBaseFilterPlanUtil.java | 612 -
.../hive/metastore/hbase/HBaseImport.java | 619 -
.../hive/metastore/hbase/HBaseReadWrite.java | 2943 -
.../hive/metastore/hbase/HBaseSchemaTool.java | 192 -
.../hadoop/hive/metastore/hbase/HBaseStore.java | 2964 -
.../hadoop/hive/metastore/hbase/HBaseUtils.java | 1781 -
.../hive/metastore/hbase/MetadataStore.java | 2 +-
.../hive/metastore/hbase/ObjectCache.java | 81 -
.../hive/metastore/hbase/PartitionCache.java | 168 -
.../metastore/hbase/PartitionKeyComparator.java | 292 -
.../hbase/SharedStorageDescriptor.java | 251 -
.../hadoop/hive/metastore/hbase/StatsCache.java | 323 -
.../metastore/hbase/TephraHBaseConnection.java | 127 -
.../metastore/hbase/VanillaHBaseConnection.java | 137 -
.../stats/BinaryColumnStatsAggregator.java | 64 -
.../stats/BooleanColumnStatsAggregator.java | 65 -
.../hbase/stats/ColumnStatsAggregator.java | 34 -
.../stats/ColumnStatsAggregatorFactory.java | 104 -
.../stats/DecimalColumnStatsAggregator.java | 351 -
.../stats/DoubleColumnStatsAggregator.java | 325 -
.../hbase/stats/IExtrapolatePartStatus.java | 47 -
.../hbase/stats/LongColumnStatsAggregator.java | 323 -
.../stats/StringColumnStatsAggregator.java | 105 -
.../stats/merge/BinaryColumnStatsMerger.java | 35 -
.../stats/merge/BooleanColumnStatsMerger.java | 35 -
.../hbase/stats/merge/ColumnStatsMerger.java | 34 -
.../stats/merge/ColumnStatsMergerFactory.java | 150 -
.../stats/merge/DateColumnStatsMerger.java | 55 -
.../stats/merge/DecimalColumnStatsMerger.java | 55 -
.../stats/merge/DoubleColumnStatsMerger.java | 48 -
.../stats/merge/LongColumnStatsMerger.java | 48 -
.../stats/merge/StringColumnStatsMerger.java | 49 -
.../metastore/hooks/JDOConnectionURLHook.java | 4 +
.../messaging/AddForeignKeyMessage.java | 36 +
.../messaging/AddNotNullConstraintMessage.java | 36 +
.../messaging/AddPartitionMessage.java | 2 +
.../messaging/AddPrimaryKeyMessage.java | 35 +
.../messaging/AddUniqueConstraintMessage.java | 36 +
.../messaging/AlterPartitionMessage.java | 2 +
.../metastore/messaging/AlterTableMessage.java | 2 +
.../metastore/messaging/CreateTableMessage.java | 2 +
.../messaging/DropConstraintMessage.java | 29 +
.../messaging/DropPartitionMessage.java | 2 +
.../metastore/messaging/DropTableMessage.java | 2 +
.../hive/metastore/messaging/EventMessage.java | 7 +-
.../hive/metastore/messaging/EventUtils.java | 13 +
.../hive/metastore/messaging/InsertMessage.java | 2 +
.../messaging/MessageDeserializer.java | 36 +-
.../metastore/messaging/MessageFactory.java | 53 +-
.../event/filters/DatabaseAndTableFilter.java | 2 +-
.../json/JSONAddForeignKeyMessage.java | 101 +
.../json/JSONAddNotNullConstraintMessage.java | 96 +
.../messaging/json/JSONAddPartitionMessage.java | 8 +-
.../json/JSONAddPrimaryKeyMessage.java | 101 +
.../json/JSONAddUniqueConstraintMessage.java | 98 +
.../json/JSONAlterPartitionMessage.java | 8 +-
.../messaging/json/JSONAlterTableMessage.java | 8 +-
.../messaging/json/JSONCreateTableMessage.java | 18 +-
.../json/JSONDropConstraintMessage.java | 90 +
.../json/JSONDropPartitionMessage.java | 15 +-
.../messaging/json/JSONDropTableMessage.java | 13 +-
.../messaging/json/JSONInsertMessage.java | 8 +-
.../messaging/json/JSONMessageDeserializer.java | 50 +
.../messaging/json/JSONMessageFactory.java | 61 +-
.../hive/metastore/parser/ExpressionTree.java | 4 +-
.../hive/metastore/tools/HiveSchemaHelper.java | 2 +-
.../hadoop/hive/metastore/txn/TxnDbUtil.java | 5 +-
.../hadoop/hive/metastore/txn/TxnHandler.java | 254 +-
.../hadoop/hive/metastore/txn/TxnStore.java | 2 +-
.../hadoop/hive/metastore/txn/TxnUtils.java | 2 +-
.../src/main/resources/thrift-replacements.txt | 60 -
.../hive/metastore/model/MColumnDescriptor.java | 51 -
.../hive/metastore/model/MConstraint.java | 188 -
.../hive/metastore/model/MDBPrivilege.java | 132 -
.../hadoop/hive/metastore/model/MDatabase.java | 128 -
.../hive/metastore/model/MDelegationToken.java | 45 -
.../hive/metastore/model/MFieldSchema.java | 80 -
.../hadoop/hive/metastore/model/MFunction.java | 119 -
.../hive/metastore/model/MGlobalPrivilege.java | 120 -
.../hadoop/hive/metastore/model/MIndex.java | 200 -
.../hadoop/hive/metastore/model/MMasterKey.java | 55 -
.../metastore/model/MMetastoreDBProperties.java | 56 -
.../hive/metastore/model/MNotificationLog.java | 98 -
.../metastore/model/MNotificationNextId.java | 42 -
.../hadoop/hive/metastore/model/MOrder.java | 62 -
.../hadoop/hive/metastore/model/MPartition.java | 155 -
.../model/MPartitionColumnPrivilege.java | 161 -
.../model/MPartitionColumnStatistics.java | 258 -
.../hive/metastore/model/MPartitionEvent.java | 90 -
.../metastore/model/MPartitionPrivilege.java | 139 -
.../hive/metastore/model/MPrincipalDesc.java | 59 -
.../hive/metastore/model/MResourceUri.java | 49 -
.../hadoop/hive/metastore/model/MRole.java | 80 -
.../hadoop/hive/metastore/model/MRoleMap.java | 120 -
.../hadoop/hive/metastore/model/MSerDeInfo.java | 81 -
.../metastore/model/MStorageDescriptor.java | 277 -
.../hive/metastore/model/MStringList.java | 62 -
.../hadoop/hive/metastore/model/MTable.java | 256 -
.../metastore/model/MTableColumnPrivilege.java | 160 -
.../metastore/model/MTableColumnStatistics.java | 249 -
.../hive/metastore/model/MTablePrivilege.java | 139 -
.../hadoop/hive/metastore/model/MType.java | 105 -
.../hive/metastore/model/MVersionTable.java | 57 -
metastore/src/model/package.jdo | 1081 -
.../metastore/hbase/hbase_metastore_proto.proto | 368 -
.../DummyRawStoreControlledCommit.java | 29 +-
.../DummyRawStoreForJdoConnection.java | 26 +-
.../InjectableBehaviourObjectStore.java | 26 +-
.../hadoop/hive/metastore/TestObjectStore.java | 25 +-
.../hadoop/hive/metastore/TestOldSchema.java | 220 +
.../hive/metastore/cache/TestCachedStore.java | 230 +-
.../TestDataSourceProviderFactory.java | 167 +
.../hadoop/hive/metastore/hbase/MockUtils.java | 219 -
.../hbase/TestHBaseAggregateStatsCache.java | 316 -
...stHBaseAggregateStatsCacheWithBitVector.java | 184 -
.../TestHBaseAggregateStatsExtrapolation.java | 716 -
.../TestHBaseAggregateStatsNDVUniformDist.java | 580 -
.../hbase/TestHBaseFilterPlanUtil.java | 483 -
.../hive/metastore/hbase/TestHBaseStore.java | 1978 -
.../hbase/TestHBaseStoreBitVector.java | 622 -
.../metastore/hbase/TestHBaseStoreCached.java | 365 -
.../hbase/TestSharedStorageDescriptor.java | 152 -
pom.xml | 55 +-
ql/if/queryplan.thrift | 3 +
ql/pom.xml | 10 +-
ql/src/gen/thrift/gen-cpp/queryplan_types.cpp | 12 +-
ql/src/gen/thrift/gen-cpp/queryplan_types.h | 5 +-
.../hadoop/hive/ql/plan/api/StageType.java | 11 +-
ql/src/gen/thrift/gen-php/Types.php | 6 +
ql/src/gen/thrift/gen-py/queryplan/ttypes.py | 9 +
ql/src/gen/thrift/gen-rb/queryplan_types.rb | 7 +-
.../UDAFTemplates/VectorUDAFAvg.txt | 255 +-
.../UDAFTemplates/VectorUDAFAvgDecimal.txt | 566 +
.../UDAFTemplates/VectorUDAFAvgDecimalMerge.txt | 597 +
.../UDAFTemplates/VectorUDAFAvgMerge.txt | 547 +
.../UDAFTemplates/VectorUDAFAvgTimestamp.txt | 517 +
.../UDAFTemplates/VectorUDAFMinMax.txt | 184 +-
.../UDAFTemplates/VectorUDAFMinMaxDecimal.txt | 30 +-
.../VectorUDAFMinMaxIntervalDayTime.txt | 26 +-
.../UDAFTemplates/VectorUDAFMinMaxString.txt | 29 +-
.../UDAFTemplates/VectorUDAFMinMaxTimestamp.txt | 26 +-
.../UDAFTemplates/VectorUDAFSum.txt | 139 +-
.../UDAFTemplates/VectorUDAFVar.txt | 194 +-
.../UDAFTemplates/VectorUDAFVarDecimal.txt | 219 +-
.../UDAFTemplates/VectorUDAFVarMerge.txt | 573 +
.../UDAFTemplates/VectorUDAFVarTimestamp.txt | 477 +
.../hadoop/hive/llap/ChannelOutputStream.java | 37 +-
.../hadoop/hive/llap/LlapCacheAwareFs.java | 422 +
.../hive/llap/LlapOutputFormatService.java | 4 +-
.../hadoop/hive/llap/LlapRecordWriter.java | 6 +-
.../hadoop/hive/ql/CompilationOpContext.java | 13 +-
.../java/org/apache/hadoop/hive/ql/Context.java | 2 +-
.../java/org/apache/hadoop/hive/ql/Driver.java | 12 +
.../org/apache/hadoop/hive/ql/ErrorMsg.java | 40 +-
.../hadoop/hive/ql/HiveDriverRunHook.java | 4 +
.../hive/ql/HiveDriverRunHookContext.java | 4 +
.../apache/hadoop/hive/ql/QueryProperties.java | 1 +
.../hadoop/hive/ql/exec/CollectOperator.java | 5 +
.../hadoop/hive/ql/exec/ColumnStatsTask.java | 46 +-
.../hive/ql/exec/ColumnStatsUpdateTask.java | 24 +-
.../hadoop/hive/ql/exec/CommonJoinOperator.java | 17 +-
.../org/apache/hadoop/hive/ql/exec/DDLTask.java | 152 +-
.../hadoop/hive/ql/exec/DemuxOperator.java | 5 +
.../apache/hadoop/hive/ql/exec/Description.java | 5 +
.../apache/hadoop/hive/ql/exec/ExplainTask.java | 27 +-
.../hadoop/hive/ql/exec/FetchOperator.java | 6 -
.../hadoop/hive/ql/exec/FileSinkOperator.java | 77 +-
.../hadoop/hive/ql/exec/ForwardOperator.java | 5 +
.../hadoop/hive/ql/exec/FunctionRegistry.java | 4 +-
.../hadoop/hive/ql/exec/FunctionTask.java | 28 +-
.../hadoop/hive/ql/exec/GroupByOperator.java | 2 +-
.../hive/ql/exec/HashTableDummyOperator.java | 5 +-
.../hive/ql/exec/HashTableSinkOperator.java | 10 +-
.../hadoop/hive/ql/exec/KeyWrapperFactory.java | 6 +
.../ql/exec/LateralViewForwardOperator.java | 5 +
.../hadoop/hive/ql/exec/ListSinkOperator.java | 5 +
.../hadoop/hive/ql/exec/MapJoinOperator.java | 18 +
.../apache/hadoop/hive/ql/exec/MapOperator.java | 3 +
.../hadoop/hive/ql/exec/MapredContext.java | 2 +
.../apache/hadoop/hive/ql/exec/MoveTask.java | 48 +-
.../apache/hadoop/hive/ql/exec/MuxOperator.java | 5 +
.../apache/hadoop/hive/ql/exec/NodeUtils.java | 68 +-
.../hadoop/hive/ql/exec/ObjectCacheFactory.java | 9 +-
.../apache/hadoop/hive/ql/exec/Operator.java | 75 +
.../hadoop/hive/ql/exec/OperatorFactory.java | 3 +
.../hadoop/hive/ql/exec/OperatorUtils.java | 39 +-
.../hive/ql/exec/OrcFileMergeOperator.java | 38 +-
.../hadoop/hive/ql/exec/ReplCopyTask.java | 157 +-
.../hive/ql/exec/SerializationUtilities.java | 7 +-
.../ql/exec/SparkHashTableSinkOperator.java | 17 +-
.../hadoop/hive/ql/exec/StatsNoJobTask.java | 5 -
.../hadoop/hive/ql/exec/TableScanOperator.java | 11 +-
.../apache/hadoop/hive/ql/exec/TaskFactory.java | 10 +-
.../org/apache/hadoop/hive/ql/exec/UDF.java | 3 +
.../hive/ql/exec/UDFArgumentException.java | 4 +
.../ql/exec/UDFArgumentLengthException.java | 5 +
.../hive/ql/exec/UDFArgumentTypeException.java | 6 +-
.../hadoop/hive/ql/exec/UDFMethodResolver.java | 1 +
.../hadoop/hive/ql/exec/UnionOperator.java | 5 +
.../apache/hadoop/hive/ql/exec/Utilities.java | 509 +-
.../hive/ql/exec/errors/ErrorAndSolution.java | 5 +-
.../hadoop/hive/ql/exec/mr/MapRedTask.java | 2 +-
.../ql/exec/persistence/FlatRowContainer.java | 2 +-
.../hive/ql/exec/persistence/RowContainer.java | 10 +-
.../hadoop/hive/ql/exec/repl/ReplDumpTask.java | 325 +
.../hadoop/hive/ql/exec/repl/ReplDumpWork.java | 75 +
.../hive/ql/exec/repl/ReplStateLogTask.java | 51 +
.../hive/ql/exec/repl/ReplStateLogWork.java | 100 +
.../ql/exec/repl/bootstrap/ReplLoadTask.java | 289 +
.../ql/exec/repl/bootstrap/ReplLoadWork.java | 70 +
.../repl/bootstrap/events/BootstrapEvent.java | 28 +
.../repl/bootstrap/events/DatabaseEvent.java | 34 +
.../repl/bootstrap/events/FunctionEvent.java | 33 +
.../repl/bootstrap/events/PartitionEvent.java | 26 +
.../exec/repl/bootstrap/events/TableEvent.java | 42 +
.../filesystem/BootstrapEventsIterator.java | 181 +
.../filesystem/DatabaseEventsIterator.java | 145 +
.../events/filesystem/FSDatabaseEvent.java | 88 +
.../events/filesystem/FSFunctionEvent.java | 39 +
.../events/filesystem/FSPartitionEvent.java | 84 +
.../events/filesystem/FSTableEvent.java | 123 +
.../exec/repl/bootstrap/load/LoadDatabase.java | 129 +
.../exec/repl/bootstrap/load/LoadFunction.java | 87 +
.../repl/bootstrap/load/ReplicationState.java | 58 +
.../exec/repl/bootstrap/load/TaskTracker.java | 120 +
.../bootstrap/load/table/LoadPartitions.java | 316 +
.../repl/bootstrap/load/table/LoadTable.java | 245 +
.../repl/bootstrap/load/table/TableContext.java | 49 +
.../exec/repl/bootstrap/load/util/Context.java | 37 +
.../repl/bootstrap/load/util/PathUtils.java | 105 +
.../hive/ql/exec/spark/HashTableLoader.java | 2 +-
.../ql/exec/spark/LocalHiveSparkClient.java | 2 +-
.../ql/exec/spark/RemoteHiveSparkClient.java | 19 +-
.../hive/ql/exec/spark/RepartitionShuffler.java | 42 -
.../exec/spark/SparkDynamicPartitionPruner.java | 13 +-
.../hive/ql/exec/spark/SparkPlanGenerator.java | 6 +-
.../ql/exec/spark/SparkReduceRecordHandler.java | 331 +-
.../hive/ql/exec/spark/SparkUtilities.java | 20 +
.../ql/exec/spark/session/SparkSessionImpl.java | 11 +-
.../hadoop/hive/ql/exec/tez/DagUtils.java | 36 +-
.../hive/ql/exec/tez/MapRecordSource.java | 12 +
.../hadoop/hive/ql/exec/tez/ObjectCache.java | 5 +
.../hive/ql/exec/tez/ReduceRecordSource.java | 80 +-
.../ql/exec/tez/RestrictedConfigChecker.java | 79 +
.../ql/exec/tez/SessionExpirationTracker.java | 235 +
.../hadoop/hive/ql/exec/tez/TezSessionPool.java | 165 +
.../hive/ql/exec/tez/TezSessionPoolManager.java | 551 +-
.../hive/ql/exec/tez/TezSessionPoolSession.java | 158 +
.../apache/hadoop/hive/ql/exec/tez/TezTask.java | 84 +-
.../ql/exec/tez/tools/KeyValueInputMerger.java | 50 +-
.../vector/VectorAppMasterEventOperator.java | 3 +-
.../hive/ql/exec/vector/VectorAssignRow.java | 410 +-
.../hive/ql/exec/vector/VectorBatchDebug.java | 105 +
.../ql/exec/vector/VectorDeserializeRow.java | 492 +-
.../hive/ql/exec/vector/VectorExtractRow.java | 40 +-
.../ql/exec/vector/VectorFilterOperator.java | 2 +-
.../ql/exec/vector/VectorGroupByOperator.java | 69 +-
.../ql/exec/vector/VectorLimitOperator.java | 2 +-
.../exec/vector/VectorMapJoinBaseOperator.java | 3 +-
.../hive/ql/exec/vector/VectorMapOperator.java | 48 +-
.../exec/vector/VectorSMBMapJoinOperator.java | 2 +-
.../ql/exec/vector/VectorSelectOperator.java | 12 +-
.../ql/exec/vector/VectorizationContext.java | 247 +-
.../ql/exec/vector/VectorizedBatchUtil.java | 61 +-
.../ql/exec/vector/VectorizedRowBatchCtx.java | 55 +-
.../vector/expressions/CastDateToTimestamp.java | 131 +
.../vector/expressions/IfExprColumnNull.java | 109 +
.../vector/expressions/IfExprNullColumn.java | 109 +
.../VectorExpressionWriterFactory.java | 188 +-
.../VectorInBloomFilterColDynamicValue.java | 18 +-
.../aggregates/VectorAggregateExpression.java | 17 +-
.../aggregates/VectorUDAFAvgDecimal.java | 521 -
.../aggregates/VectorUDAFAvgTimestamp.java | 488 -
.../aggregates/VectorUDAFBloomFilter.java | 60 +-
.../aggregates/VectorUDAFBloomFilterMerge.java | 43 +-
.../expressions/aggregates/VectorUDAFCount.java | 28 +-
.../aggregates/VectorUDAFCountMerge.java | 28 +-
.../aggregates/VectorUDAFCountStar.java | 20 +-
.../aggregates/VectorUDAFStdPopTimestamp.java | 533 -
.../aggregates/VectorUDAFStdSampTimestamp.java | 533 -
.../aggregates/VectorUDAFSumDecimal.java | 39 +-
.../aggregates/VectorUDAFSumTimestamp.java | 434 +
.../aggregates/VectorUDAFVarPopTimestamp.java | 533 -
.../aggregates/VectorUDAFVarSampTimestamp.java | 533 -
.../mapjoin/VectorMapJoinCommonOperator.java | 35 +-
.../VectorMapJoinGenerateResultOperator.java | 6 +-
.../fast/VectorMapJoinFastTableContainer.java | 8 +-
.../VectorMapJoinOptimizedCreateHashTable.java | 6 +-
.../exec/vector/ptf/VectorPTFEvaluatorBase.java | 122 +
.../vector/ptf/VectorPTFEvaluatorCount.java | 108 +
.../vector/ptf/VectorPTFEvaluatorCountStar.java | 79 +
.../ptf/VectorPTFEvaluatorDecimalAvg.java | 162 +
.../VectorPTFEvaluatorDecimalFirstValue.java | 117 +
.../ptf/VectorPTFEvaluatorDecimalLastValue.java | 113 +
.../ptf/VectorPTFEvaluatorDecimalMax.java | 146 +
.../ptf/VectorPTFEvaluatorDecimalMin.java | 146 +
.../ptf/VectorPTFEvaluatorDecimalSum.java | 140 +
.../vector/ptf/VectorPTFEvaluatorDenseRank.java | 77 +
.../vector/ptf/VectorPTFEvaluatorDoubleAvg.java | 153 +
.../ptf/VectorPTFEvaluatorDoubleFirstValue.java | 113 +
.../ptf/VectorPTFEvaluatorDoubleLastValue.java | 109 +
.../vector/ptf/VectorPTFEvaluatorDoubleMax.java | 136 +
.../vector/ptf/VectorPTFEvaluatorDoubleMin.java | 136 +
.../vector/ptf/VectorPTFEvaluatorDoubleSum.java | 134 +
.../vector/ptf/VectorPTFEvaluatorLongAvg.java | 153 +
.../ptf/VectorPTFEvaluatorLongFirstValue.java | 113 +
.../ptf/VectorPTFEvaluatorLongLastValue.java | 109 +
.../vector/ptf/VectorPTFEvaluatorLongMax.java | 136 +
.../vector/ptf/VectorPTFEvaluatorLongMin.java | 136 +
.../vector/ptf/VectorPTFEvaluatorLongSum.java | 134 +
.../exec/vector/ptf/VectorPTFEvaluatorRank.java | 81 +
.../vector/ptf/VectorPTFEvaluatorRowNumber.java | 77 +
.../exec/vector/ptf/VectorPTFGroupBatches.java | 216 +
.../ql/exec/vector/ptf/VectorPTFOperator.java | 570 +
.../ql/exec/vector/udf/VectorUDFAdaptor.java | 171 +-
.../hive/ql/hooks/ExecuteWithHookContext.java | 5 +
.../org/apache/hadoop/hive/ql/hooks/Hook.java | 6 +
.../hadoop/hive/ql/hooks/HookContext.java | 4 +
.../hadoop/hive/ql/hooks/PostExecute.java | 4 +
.../apache/hadoop/hive/ql/hooks/PreExecute.java | 4 +
.../hadoop/hive/ql/hooks/QueryLifeTimeHook.java | 5 +
.../hive/ql/hooks/QueryLifeTimeHookContext.java | 4 +
.../hooks/QueryLifeTimeHookWithParseHooks.java | 5 +
.../hadoop/hive/ql/io/AcidInputFormat.java | 11 +-
.../hadoop/hive/ql/io/AcidOutputFormat.java | 33 +-
.../org/apache/hadoop/hive/ql/io/AcidUtils.java | 152 +-
.../apache/hadoop/hive/ql/io/BucketCodec.java | 128 +
.../hive/ql/io/CombineHiveInputFormat.java | 2 +-
.../org/apache/hadoop/hive/ql/io/HdfsUtils.java | 40 +-
.../hadoop/hive/ql/io/HiveFileFormatUtils.java | 2 +-
.../hadoop/hive/ql/io/HiveInputFormat.java | 106 +-
.../io/LlapCacheOnlyInputFormatInterface.java | 28 +
.../hadoop/hive/ql/io/RecordIdentifier.java | 21 +-
.../hadoop/hive/ql/io/orc/ExternalCache.java | 2 +-
.../hive/ql/io/orc/OrcFileKeyWrapper.java | 36 +-
.../io/orc/OrcFileStripeMergeRecordReader.java | 5 +-
.../hadoop/hive/ql/io/orc/OrcInputFormat.java | 190 +-
.../hadoop/hive/ql/io/orc/OrcOutputFormat.java | 2 +-
.../hive/ql/io/orc/OrcRawRecordMerger.java | 773 +-
.../hadoop/hive/ql/io/orc/OrcRecordUpdater.java | 160 +-
.../apache/hadoop/hive/ql/io/orc/OrcSplit.java | 10 +-
.../io/orc/VectorizedOrcAcidRowBatchReader.java | 207 +-
.../hive/ql/io/orc/encoded/EncodedReader.java | 3 +-
.../ql/io/orc/encoded/EncodedReaderImpl.java | 538 +-
.../hive/ql/io/orc/encoded/IncompleteCb.java | 7 +
.../hadoop/hive/ql/io/orc/encoded/IoTrace.java | 478 +
.../hadoop/hive/ql/io/orc/encoded/Reader.java | 2 +-
.../hive/ql/io/orc/encoded/ReaderImpl.java | 6 +-
.../ql/io/parquet/MapredParquetInputFormat.java | 47 +-
.../io/parquet/MapredParquetOutputFormat.java | 30 +-
.../ql/io/parquet/ParquetRecordReaderBase.java | 54 +-
.../hive/ql/io/parquet/ProjectionPusher.java | 4 +-
.../parquet/VectorizedParquetInputFormat.java | 22 +-
.../ql/io/parquet/convert/ETypeConverter.java | 24 +-
.../hive/ql/io/parquet/convert/Repeated.java | 1 -
.../parquet/read/DataWritableReadSupport.java | 21 +-
.../read/ParquetFilterPredicateConverter.java | 13 +-
.../read/ParquetRecordReaderWrapper.java | 26 +-
.../ql/io/parquet/serde/ParquetTableUtils.java | 31 +-
.../ql/io/parquet/timestamp/NanoTimeUtils.java | 247 +-
.../vector/ParquetFooterInputFromCache.java | 196 +
.../vector/VectorizedParquetRecordReader.java | 202 +-
.../vector/VectorizedPrimitiveColumnReader.java | 21 +-
.../parquet/write/DataWritableWriteSupport.java | 14 +-
.../ql/io/parquet/write/DataWritableWriter.java | 10 +-
.../write/ParquetRecordWriterWrapper.java | 24 +
.../apache/hadoop/hive/ql/lib/RuleRegExp.java | 3 +
.../hadoop/hive/ql/lockmgr/DbTxnManager.java | 18 +-
.../hive/ql/lockmgr/EmbeddedLockManager.java | 22 +-
.../zookeeper/ZooKeeperHiveLockManager.java | 13 +-
.../hadoop/hive/ql/log/LogDivertAppender.java | 15 +-
.../hive/ql/log/LogDivertAppenderForTest.java | 8 +-
.../apache/hadoop/hive/ql/metadata/Hive.java | 174 +-
.../hadoop/hive/ql/metadata/HiveException.java | 38 +-
.../metadata/HiveMaterializedViewsRegistry.java | 9 +-
.../hive/ql/metadata/HiveStorageHandler.java | 4 +
.../metadata/HiveStoragePredicateHandler.java | 6 +
.../hadoop/hive/ql/metadata/InputEstimator.java | 4 +
.../ql/metadata/SessionHiveMetaStoreClient.java | 13 +
.../hadoop/hive/ql/metadata/VirtualColumn.java | 14 +
.../formatting/MetaDataFormatUtils.java | 35 +-
.../BucketingSortingReduceSinkOptimizer.java | 7 +-
.../optimizer/ConstantPropagateProcFactory.java | 6 +-
.../hive/ql/optimizer/ConvertJoinMapJoin.java | 89 +-
.../ql/optimizer/CountDistinctRewriteProc.java | 64 +-
.../DynamicPartitionPruningOptimization.java | 151 +-
.../hive/ql/optimizer/GenMapRedUtils.java | 5 +
.../hive/ql/optimizer/MapJoinProcessor.java | 5 +-
.../ql/optimizer/OperatorComparatorFactory.java | 552 -
.../hadoop/hive/ql/optimizer/Optimizer.java | 4 +-
.../ql/optimizer/ReduceSinkMapJoinProc.java | 6 +-
.../hive/ql/optimizer/SharedScanOptimizer.java | 626 -
.../hive/ql/optimizer/SharedWorkOptimizer.java | 1177 +
.../optimizer/SortedDynPartitionOptimizer.java | 1 +
.../ql/optimizer/SparkRemoveDynamicPruning.java | 80 +
.../SparkRemoveDynamicPruningBySize.java | 65 -
.../hive/ql/optimizer/StatsOptimizer.java | 17 +-
.../ql/optimizer/calcite/HiveCalciteUtil.java | 9 +-
.../calcite/HiveConfPlannerContext.java | 34 +
.../optimizer/calcite/HivePlannerContext.java | 7 +-
.../hive/ql/optimizer/calcite/HiveType.java | 48 +
.../optimizer/calcite/HiveTypeSystemImpl.java | 17 +-
.../ql/optimizer/calcite/RelOptHiveTable.java | 63 +-
.../calcite/cost/HiveAlgorithmsUtil.java | 10 +-
.../calcite/cost/HiveDefaultCostModel.java | 2 +-
.../calcite/cost/HiveOnTezCostModel.java | 35 +-
.../calcite/reloperators/HiveAggregate.java | 13 +-
.../calcite/reloperators/HiveIntersect.java | 10 +
.../calcite/reloperators/HiveJoin.java | 5 +-
.../calcite/reloperators/HiveTableScan.java | 50 +-
.../calcite/reloperators/HiveUnion.java | 9 +
.../rules/HiveAggregateJoinTransposeRule.java | 2 +-
.../calcite/rules/HiveAggregateReduceRule.java | 126 +
.../HiveDruidProjectFilterTransposeRule.java | 48 -
.../rules/HiveExpandDistinctAggregatesRule.java | 3 +-
.../rules/HiveFilterSetOpTransposeRule.java | 98 +-
.../calcite/rules/HiveJoinAddNotNullRule.java | 42 +-
.../HiveJoinPushTransitivePredicatesRule.java | 2 +-
.../rules/HiveReduceExpressionsRule.java | 2 +-
.../HiveReduceExpressionsWithStatsRule.java | 2 +-
.../calcite/rules/HiveRelDecorrelator.java | 306 +-
.../calcite/rules/HiveRelFieldTrimmer.java | 2 +-
.../calcite/rules/HiveRemoveSqCountCheck.java | 142 +
.../calcite/rules/HiveSemiJoinRule.java | 96 +-
.../calcite/rules/HiveSortJoinReduceRule.java | 3 +-
.../rules/HiveSortLimitPullUpConstantsRule.java | 2 +-
.../calcite/rules/HiveSortRemoveRule.java | 2 +-
.../calcite/rules/HiveSortUnionReduceRule.java | 2 +-
.../calcite/rules/HiveSubQueryRemoveRule.java | 620 +-
.../calcite/rules/HiveUnionMergeRule.java | 84 +
.../rules/HiveUnionPullUpConstantsRule.java | 2 +-
.../HiveMaterializedViewFilterScanRule.java | 92 -
.../rules/views/HiveMaterializedViewRule.java | 38 +
.../MaterializedViewSubstitutionVisitor.java | 292 -
.../rules/views/SubstitutionVisitor.java | 2458 -
.../calcite/stats/HiveRelMdSelectivity.java | 33 +-
.../calcite/translator/ASTBuilder.java | 31 +-
.../calcite/translator/ExprNodeConverter.java | 32 +-
.../calcite/translator/RexNodeConverter.java | 65 +-
.../translator/SqlFunctionConverter.java | 7 +-
.../calcite/translator/TypeConverter.java | 17 +-
.../correlation/CorrelationUtilities.java | 51 +-
.../correlation/ReduceSinkDeDuplication.java | 476 +-
.../ReduceSinkDeDuplicationUtils.java | 584 +
.../ReduceSinkJoinDeDuplication.java | 255 +
.../ql/optimizer/lineage/ExprProcFactory.java | 48 +-
.../hive/ql/optimizer/lineage/Generator.java | 27 +
.../ql/optimizer/lineage/OpProcFactory.java | 36 +-
.../hive/ql/optimizer/physical/LlapDecider.java | 2 +-
.../hive/ql/optimizer/physical/Vectorizer.java | 944 +-
.../hive/ql/optimizer/ppr/PartitionPruner.java | 23 +-
.../spark/CombineEquivalentWorkResolver.java | 79 +-
.../spark/SetSparkReducerParallelism.java | 141 +-
.../optimizer/spark/SparkMapJoinOptimizer.java | 50 +
.../spark/SparkPartitionPruningSinkDesc.java | 17 +-
.../stats/annotation/StatsRulesProcFactory.java | 263 +-
.../hadoop/hive/ql/parse/CalcitePlanner.java | 70 +-
.../hadoop/hive/ql/parse/ColumnStatsList.java | 64 +
.../ql/parse/ColumnStatsSemanticAnalyzer.java | 36 +-
.../hive/ql/parse/DDLSemanticAnalyzer.java | 49 +-
.../apache/hadoop/hive/ql/parse/EximUtil.java | 39 +-
.../hive/ql/parse/ExportSemanticAnalyzer.java | 243 +-
.../hive/ql/parse/FunctionSemanticAnalyzer.java | 4 +-
.../hadoop/hive/ql/parse/GenTezUtils.java | 232 +-
.../org/apache/hadoop/hive/ql/parse/HiveLexer.g | 2 +-
.../apache/hadoop/hive/ql/parse/HiveParser.g | 19 +-
.../hive/ql/parse/HiveSemanticAnalyzerHook.java | 4 +
.../parse/HiveSemanticAnalyzerHookContext.java | 9 +
.../HiveSemanticAnalyzerHookContextImpl.java | 12 +
.../hive/ql/parse/ImportSemanticAnalyzer.java | 177 +-
.../hive/ql/parse/LoadSemanticAnalyzer.java | 5 +
.../hadoop/hive/ql/parse/ParseContext.java | 30 +-
.../hive/ql/parse/PrunedPartitionList.java | 21 +-
.../apache/hadoop/hive/ql/parse/QBSubQuery.java | 23 +-
.../ql/parse/ReplicationSemanticAnalyzer.java | 782 +-
.../hadoop/hive/ql/parse/ReplicationSpec.java | 146 +-
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 158 +-
.../hive/ql/parse/SemanticAnalyzerFactory.java | 8 +-
.../hadoop/hive/ql/parse/SemanticException.java | 5 +-
.../hadoop/hive/ql/parse/SemiJoinHint.java | 13 +-
.../hadoop/hive/ql/parse/TezCompiler.java | 85 +-
.../hive/ql/parse/TypeCheckProcFactory.java | 21 +-
.../ql/parse/UpdateDeleteSemanticAnalyzer.java | 10 +-
.../hadoop/hive/ql/parse/repl/CopyUtils.java | 136 +
.../hadoop/hive/ql/parse/repl/DumpType.java | 35 +
.../hadoop/hive/ql/parse/repl/ReplLogger.java | 36 +
.../hadoop/hive/ql/parse/repl/ReplState.java | 57 +
.../dump/BootStrapReplicationSpecFunction.java | 5 +-
.../hive/ql/parse/repl/dump/HiveWrapper.java | 2 +-
.../ql/parse/repl/dump/PartitionExport.java | 119 +
.../hive/ql/parse/repl/dump/TableExport.java | 274 +
.../hadoop/hive/ql/parse/repl/dump/Utils.java | 32 +
.../repl/dump/events/AddForeignKeyHandler.java | 41 +
.../events/AddNotNullConstraintHandler.java | 41 +
.../repl/dump/events/AddPartitionHandler.java | 3 +-
.../repl/dump/events/AddPrimaryKeyHandler.java | 41 +
.../dump/events/AddUniqueConstraintHandler.java | 41 +
.../repl/dump/events/CreateTableHandler.java | 8 +-
.../repl/dump/events/DropConstraintHandler.java | 41 +
.../repl/dump/events/EventHandlerFactory.java | 5 +
.../ql/parse/repl/dump/io/FileOperations.java | 112 +
.../parse/repl/dump/io/FunctionSerializer.java | 2 +-
.../parse/repl/dump/io/PartitionSerializer.java | 11 +-
.../ql/parse/repl/dump/io/TableSerializer.java | 22 +-
.../repl/dump/log/BootstrapDumpLogger.java | 71 +
.../repl/dump/log/IncrementalDumpLogger.java | 55 +
.../repl/dump/log/state/BootstrapDumpBegin.java | 47 +
.../repl/dump/log/state/BootstrapDumpEnd.java | 59 +
.../dump/log/state/BootstrapDumpFunction.java | 44 +
.../repl/dump/log/state/BootstrapDumpTable.java | 52 +
.../dump/log/state/IncrementalDumpBegin.java | 43 +
.../repl/dump/log/state/IncrementalDumpEnd.java | 54 +
.../dump/log/state/IncrementalDumpEvent.java | 51 +
.../hive/ql/parse/repl/load/DumpMetaData.java | 11 +-
.../parse/repl/load/EventDumpDirComparator.java | 38 +
.../parse/repl/load/UpdatedMetaDataTracker.java | 76 +
.../repl/load/log/BootstrapLoadLogger.java | 66 +
.../repl/load/log/IncrementalLoadLogger.java | 55 +
.../repl/load/log/state/BootstrapLoadBegin.java | 51 +
.../repl/load/log/state/BootstrapLoadEnd.java | 59 +
.../load/log/state/BootstrapLoadFunction.java | 44 +
.../repl/load/log/state/BootstrapLoadTable.java | 52 +
.../load/log/state/IncrementalLoadBegin.java | 47 +
.../repl/load/log/state/IncrementalLoadEnd.java | 54 +
.../load/log/state/IncrementalLoadEvent.java | 51 +
.../load/message/AbstractMessageHandler.java | 25 +-
.../repl/load/message/AddForeignKeyHandler.java | 70 +
.../message/AddNotNullConstraintHandler.java | 71 +
.../repl/load/message/AddPrimaryKeyHandler.java | 68 +
.../message/AddUniqueConstraintHandler.java | 69 +
.../load/message/CreateFunctionHandler.java | 20 +-
.../load/message/DropConstraintHandler.java | 50 +
.../repl/load/message/DropFunctionHandler.java | 5 +-
.../repl/load/message/DropPartitionHandler.java | 5 +-
.../repl/load/message/DropTableHandler.java | 5 +-
.../parse/repl/load/message/InsertHandler.java | 3 +-
.../parse/repl/load/message/MessageHandler.java | 21 +-
.../load/message/RenamePartitionHandler.java | 15 +-
.../repl/load/message/RenameTableHandler.java | 24 +-
.../parse/repl/load/message/TableHandler.java | 23 +-
.../load/message/TruncatePartitionHandler.java | 11 +-
.../repl/load/message/TruncateTableHandler.java | 8 +-
.../ql/parse/spark/GenSparkProcContext.java | 5 +
.../hive/ql/parse/spark/GenSparkUtils.java | 124 +-
.../hive/ql/parse/spark/GenSparkWork.java | 2 +-
.../hive/ql/parse/spark/SparkCompiler.java | 32 +-
.../SparkPartitionPruningSinkOperator.java | 51 +-
.../parse/spark/SparkProcessAnalyzeTable.java | 17 +-
.../hive/ql/parse/spark/SplitOpTreeForDPP.java | 131 +-
.../hive/ql/plan/AbstractOperatorDesc.java | 9 +
.../hadoop/hive/ql/plan/AlterDatabaseDesc.java | 37 +-
.../hadoop/hive/ql/plan/AlterTableDesc.java | 48 +-
.../hadoop/hive/ql/plan/AppMasterEventDesc.java | 12 +
.../hadoop/hive/ql/plan/ColStatistics.java | 3 -
.../hive/ql/plan/CommonMergeJoinDesc.java | 9 +
.../ql/plan/ConditionalResolverMergeFiles.java | 11 +-
.../hadoop/hive/ql/plan/CreateFunctionDesc.java | 15 +-
.../hadoop/hive/ql/plan/DescTableDesc.java | 4 +-
.../hadoop/hive/ql/plan/DropFunctionDesc.java | 16 +-
.../hive/ql/plan/DynamicPruningEventDesc.java | 24 +
.../hadoop/hive/ql/plan/DynamicValue.java | 4 +
.../hadoop/hive/ql/plan/ExprNodeDescUtils.java | 21 +
.../hadoop/hive/ql/plan/FileSinkDesc.java | 29 +
.../apache/hadoop/hive/ql/plan/FilterDesc.java | 12 +
.../apache/hadoop/hive/ql/plan/GroupByDesc.java | 82 +-
.../hadoop/hive/ql/plan/HashTableSinkDesc.java | 10 +
.../hadoop/hive/ql/plan/HiveOperation.java | 4 +
.../hadoop/hive/ql/plan/ImportTableDesc.java | 71 +-
.../apache/hadoop/hive/ql/plan/JoinDesc.java | 15 +
.../hive/ql/plan/LateralViewJoinDesc.java | 11 +
.../apache/hadoop/hive/ql/plan/LimitDesc.java | 9 +
.../apache/hadoop/hive/ql/plan/MapJoinDesc.java | 19 +-
.../org/apache/hadoop/hive/ql/plan/MapWork.java | 49 +-
.../hadoop/hive/ql/plan/OperatorDesc.java | 1 +
.../org/apache/hadoop/hive/ql/plan/PTFDesc.java | 112 +
.../hadoop/hive/ql/plan/ReduceSinkDesc.java | 25 +
.../hive/ql/plan/RenamePartitionDesc.java | 22 +-
.../hadoop/hive/ql/plan/ReplCopyWork.java | 82 +-
.../apache/hadoop/hive/ql/plan/ScriptDesc.java | 11 +
.../apache/hadoop/hive/ql/plan/SelectDesc.java | 12 +
.../apache/hadoop/hive/ql/plan/Statistics.java | 23 +-
.../hadoop/hive/ql/plan/TableScanDesc.java | 26 +
.../hadoop/hive/ql/plan/TezEdgeProperty.java | 7 +-
.../hadoop/hive/ql/plan/TruncateTableDesc.java | 11 +-
.../apache/hadoop/hive/ql/plan/UDTFDesc.java | 12 +
.../hadoop/hive/ql/plan/VectorGroupByDesc.java | 18 +
.../hadoop/hive/ql/plan/VectorMapJoinDesc.java | 24 +-
.../hadoop/hive/ql/plan/VectorPTFDesc.java | 360 +
.../hadoop/hive/ql/plan/VectorPTFInfo.java | 161 +
.../hadoop/hive/ql/plan/ptf/WindowFrameDef.java | 6 +-
.../hive/ql/ppd/SyntheticJoinPredicate.java | 2 +-
.../hadoop/hive/ql/processors/DfsProcessor.java | 60 +-
.../hadoop/hive/ql/processors/SetProcessor.java | 11 +
.../AuthorizationPreEventListener.java | 19 +
.../authorization/plugin/HiveOperationType.java | 4 +
.../plugin/sqlstd/Operation2Privilege.java | 31 +
.../sqlstd/SQLStdHiveAccessController.java | 3 +-
.../SQLStdHiveAuthorizationValidator.java | 9 +
.../hadoop/hive/ql/session/LineageState.java | 14 +
.../hadoop/hive/ql/session/OperationLog.java | 6 +-
.../hive/ql/stats/ClientStatsPublisher.java | 6 +
.../hadoop/hive/ql/stats/StatsAggregator.java | 6 +-
.../hive/ql/stats/StatsCollectionContext.java | 5 +
.../hadoop/hive/ql/stats/StatsPublisher.java | 6 +-
.../apache/hadoop/hive/ql/stats/StatsUtils.java | 289 +-
.../hive/ql/txn/compactor/CompactorMR.java | 14 +-
.../apache/hadoop/hive/ql/udf/UDFToBoolean.java | 2 +-
.../apache/hadoop/hive/ql/udf/UDFToInteger.java | 5 +-
.../apache/hadoop/hive/ql/udf/UDFToString.java | 4 +-
.../generic/AbstractGenericUDAFResolver.java | 1 +
.../hadoop/hive/ql/udf/generic/Collector.java | 4 +
.../DecimalNumDistinctValueEstimator.java | 42 -
.../DoubleNumDistinctValueEstimator.java | 39 -
.../hive/ql/udf/generic/GenericUDAFAverage.java | 10 +-
.../ql/udf/generic/GenericUDAFBloomFilter.java | 32 +-
.../ql/udf/generic/GenericUDAFComputeStats.java | 381 +-
.../ql/udf/generic/GenericUDAFEvaluator.java | 8 +
.../GenericUDAFMkCollectionEvaluator.java | 2 +-
.../udf/generic/GenericUDAFParameterInfo.java | 4 +
.../ql/udf/generic/GenericUDAFResolver2.java | 1 +
.../ql/udf/generic/GenericUDAFStdSample.java | 13 +-
.../hive/ql/udf/generic/GenericUDAFSum.java | 25 +-
.../udf/generic/GenericUDAFVarianceSample.java | 13 +-
.../hadoop/hive/ql/udf/generic/GenericUDF.java | 12 +-
.../hive/ql/udf/generic/GenericUDFDate.java | 4 +-
.../ql/udf/generic/GenericUDFInBloomFilter.java | 16 +-
.../hive/ql/udf/generic/GenericUDFLeadLag.java | 4 +-
.../ql/udf/generic/GenericUDFTimestamp.java | 3 +-
.../generic/GenericUDFToTimestampLocalTZ.java | 113 +
.../ql/udf/generic/GenericUDFToTimestampTZ.java | 89 -
.../hadoop/hive/ql/udf/generic/GenericUDTF.java | 5 +-
.../ql/udf/generic/GenericUDTFGetSplits.java | 20 +-
.../generic/LongNumDistinctValueEstimator.java | 43 -
.../udf/generic/NumDistinctValueEstimator.java | 383 -
.../StringNumDistinctValueEstimator.java | 39 -
.../apache/hadoop/hive/ql/TestTxnCommands.java | 250 +-
.../apache/hadoop/hive/ql/TestTxnCommands2.java | 553 +-
.../ql/TestTxnCommands2WithSplitUpdate.java | 586 -
...ommands2WithSplitUpdateAndVectorization.java | 4 +-
.../hadoop/hive/ql/TestTxnCommandsBase.java | 162 +
.../apache/hadoop/hive/ql/TestTxnNoBuckets.java | 297 +
.../hive/ql/exec/TestKeyWrapperFactory.java | 113 +
.../hadoop/hive/ql/exec/TestUtilities.java | 224 +
.../ql/exec/persistence/TestRowContainer.java | 75 +
.../repl/bootstrap/load/TaskTrackerTest.java | 46 +
.../hive/ql/exec/spark/TestSparkTask.java | 49 +
.../hive/ql/exec/tez/SampleTezSessionState.java | 3 +-
.../hadoop/hive/ql/exec/tez/TestDagUtils.java | 69 +
.../hive/ql/exec/tez/TestTezSessionPool.java | 46 +-
.../hadoop/hive/ql/exec/tez/TestTezTask.java | 6 +-
.../hive/ql/exec/util/DescriptionTest.java | 31 +
.../CollectorTestOperator.java | 47 +
.../CountCollectorTestOperator.java | 48 +
.../CountVectorCollectorTestOperator.java | 47 +
.../RowCollectorTestOperator.java | 52 +
.../RowCollectorTestOperatorBase.java | 32 +
.../RowVectorCollectorTestOperator.java | 63 +
.../ql/exec/util/rowobjects/RowTestObjects.java | 100 +
.../exec/util/rowobjects/RowTestObjectsMap.java | 77 +
.../util/rowobjects/RowTestObjectsMultiSet.java | 91 +
.../exec/vector/TestVectorGroupByOperator.java | 2 +-
.../exec/vector/TestVectorSelectOperator.java | 3 +-
.../expressions/TestVectorMathFunctions.java | 22 +
.../vector/expressions/TestVectorTypeCasts.java | 16 +
.../exec/vector/mapjoin/MapJoinTestConfig.java | 658 +
.../ql/exec/vector/mapjoin/MapJoinTestData.java | 272 +
.../vector/mapjoin/MapJoinTestDescription.java | 239 +
.../vector/mapjoin/TestMapJoinOperator.java | 549 +
.../util/batchgen/TestVectorBatchGenerate.java | 57 +
.../batchgen/VectorBatchGenerateStream.java | 63 +
.../util/batchgen/VectorBatchGenerateUtil.java | 92 +
.../util/batchgen/VectorBatchGenerator.java | 306 +
.../batchgen/VectorColumnGroupGenerator.java | 494 +
.../apache/hadoop/hive/ql/io/TestAcidUtils.java | 64 +-
.../hive/ql/io/orc/TestInputOutputFormat.java | 772 +-
.../hive/ql/io/orc/TestOrcRawRecordMerger.java | 745 +-
.../hive/ql/io/orc/TestOrcRecordUpdater.java | 51 +-
.../TestVectorizedOrcAcidRowBatchReader.java | 8 +-
.../io/orc/encoded/TestEncodedReaderImpl.java | 14 +-
.../io/parquet/AbstractTestParquetDirect.java | 7 +-
.../ql/io/parquet/TestDataWritableWriter.java | 65 +-
.../parquet/TestMapredParquetOutputFormat.java | 10 -
.../io/parquet/TestParquetRowGroupFilter.java | 3 -
.../io/parquet/TestVectorizedColumnReader.java | 2 +-
.../parquet/VectorizedColumnReaderTestBase.java | 16 +-
.../io/parquet/convert/TestETypeConverter.java | 124 -
.../read/TestParquetFilterPredicate.java | 56 +-
.../serde/TestParquetTimestampUtils.java | 263 +
.../io/parquet/timestamp/TestNanoTimeUtils.java | 256 -
.../TestParquetTimestampConverter.java | 264 -
.../hive/ql/lockmgr/TestDbTxnManager2.java | 6 -
...TestGenMapRedUtilsCreateConditionalTask.java | 2 +
.../calcite/TestCBORuleFiredOnlyOnce.java | 2 +-
.../ql/optimizer/physical/TestVectorizer.java | 10 +-
.../parse/TestReplicationSemanticAnalyzer.java | 71 +-
.../hive/ql/parse/repl/CopyUtilsTest.java | 47 +
.../repl/load/TestEventDumpDirComparator.java | 44 +
.../PrimaryToReplicaResourceFunctionTest.java | 18 +
.../processors/TestCommandProcessorFactory.java | 2 +
.../hive/ql/txn/compactor/CompactorTest.java | 8 +
.../hive/ql/txn/compactor/TestWorker.java | 125 +-
.../queries/clientnegative/acid_overwrite.q | 8 -
.../alter_table_non_partitioned_table_cascade.q | 4 +
.../queries/clientnegative/create_not_acid.q | 2 +-
.../clientnegative/load_data_into_acid.q | 22 +
.../parquet_alter_part_table_drop_columns.q | 22 +
.../parquet_int96_alter_invalid_timezone.q | 5 -
.../parquet_int96_create_invalid_timezone.q | 3 -
.../clientnegative/repl_dump_requires_admin.q | 38 +
.../clientnegative/repl_load_requires_admin.q | 41 +
.../subquery_scalar_implicit_gby.q | 1 -
.../clientpositive/acid_bucket_pruning.q | 8 +-
.../clientpositive/acid_insert_overwrite.q | 73 +
.../queries/clientpositive/acid_no_buckets.q | 210 +
.../alter_partition_onto_nocurrent_db.q | 15 +
...lter_table_update_status_disable_bitvector.q | 139 +
.../clientpositive/authorization_view_8.q | 23 +
ql/src/test/queries/clientpositive/bitvector.q | 3 +
.../clientpositive/bucket_num_reducers_acid.q | 30 +
.../clientpositive/bucket_num_reducers_acid2.q | 33 +
ql/src/test/queries/clientpositive/char_udf1.q | 4 +-
.../queries/clientpositive/cmdwithcomments.q | 2 +
.../queries/clientpositive/compute_stats_date.q | 2 +-
.../clientpositive/compute_stats_decimal.q | 2 +-
.../clientpositive/compute_stats_double.q | 2 +-
.../queries/clientpositive/compute_stats_long.q | 2 +-
.../clientpositive/compute_stats_string.q | 2 +-
ql/src/test/queries/clientpositive/concat_op.q | 8 +-
.../queries/clientpositive/constprog_semijoin.q | 2 +
.../clientpositive/correlationoptimizer14.q | 1 +
.../queries/clientpositive/count_dist_rewrite.q | 2 +
ql/src/test/queries/clientpositive/dfscmd.q | 7 +
.../clientpositive/dynamic_semijoin_reduction.q | 22 +-
.../dynamic_semijoin_reduction_3.q | 2 +-
.../dynamic_semijoin_reduction_sw.q | 60 +
.../clientpositive/explaindenpendencydiffengs.q | 10 +
.../test/queries/clientpositive/filter_union.q | 56 +
ql/src/test/queries/clientpositive/fm-sketch.q | 58 +
.../clientpositive/groupby_distinct_samekey.q | 1 +
ql/src/test/queries/clientpositive/hll.q | 57 +
ql/src/test/queries/clientpositive/innerjoin1.q | 19 +
ql/src/test/queries/clientpositive/input20.q | 8 +-
ql/src/test/queries/clientpositive/input33.q | 8 +-
.../test/queries/clientpositive/input3_limit.q | 6 +-
.../queries/clientpositive/insert_orig_table.q | 20 +-
.../clientpositive/insert_overwrite_directory.q | 4 +-
.../clientpositive/insert_values_orig_table.q | 20 +-
.../insert_values_orig_table_use_metadata.q | 23 +-
.../test/queries/clientpositive/jdbc_handler.q | 7 +-
ql/src/test/queries/clientpositive/join47.q | 204 +
.../queries/clientpositive/join_max_hashtable.q | 13 +
ql/src/test/queries/clientpositive/llap_smb.q | 53 +
.../test/queries/clientpositive/localtimezone.q | 95 +
ql/src/test/queries/clientpositive/mapjoin47.q | 206 +
.../clientpositive/materialized_view_create.q | 6 +
.../materialized_view_create_rewrite.q | 2 +
ql/src/test/queries/clientpositive/mm_all.q | 45 -
.../test/queries/clientpositive/mm_loaddata.q | 53 +
.../queries/clientpositive/orc_empty_table.q | 11 +
.../clientpositive/orc_merge_incompat_schema.q | 47 +
.../orc_merge_incompat_writer_version.q | 30 +
.../clientpositive/parquet_int96_timestamp.q | 85 -
.../clientpositive/parquet_no_row_serde.q | 25 +
.../clientpositive/parquet_ppd_decimal.q | 1 +
.../clientpositive/parquet_predicate_pushdown.q | 1 +
.../parquet_predicate_pushdown_2.q | 7 +
.../parquet_timestamp_conversion.q | 13 -
.../test/queries/clientpositive/parquet_types.q | 1 +
.../parquet_types_vectorization.q | 1 +
ql/src/test/queries/clientpositive/partialdhj.q | 54 +
.../test/queries/clientpositive/perf/query11.q | 77 +
.../test/queries/clientpositive/perf/query28.q | 2 +
ql/src/test/queries/clientpositive/ppd2.q | 2 +
.../queries/clientpositive/ppd_join_filter.q | 2 +
.../reduceSinkDeDuplication_pRS_key_empty.q | 10 +-
.../reduce_deduplicate_extended.q | 1 +
.../test/queries/clientpositive/semijoin_hint.q | 32 +-
.../clientpositive/set_processor_namespaces.q | 8 +
ql/src/test/queries/clientpositive/skewjoin.q | 1 +
.../queries/clientpositive/smb_mapjoin_20.q | 13 +
.../queries/clientpositive/smb_mapjoin_47.q | 211 +
.../clientpositive/spark_constprog_dpp.q | 17 +
.../spark_dynamic_partition_pruning.q | 56 +-
.../spark_dynamic_partition_pruning_2.q | 16 +
.../spark_dynamic_partition_pruning_3.q | 228 +
...ark_dynamic_partition_pruning_mapjoin_only.q | 50 +
.../spark_explain_groupbyshuffle.q | 8 +
.../spark_multi_insert_parallel_orderby.q | 67 +
.../queries/clientpositive/spark_union_merge.q | 41 +
.../spark_use_ts_stats_for_mapjoin.q | 1 +
...spark_vectorized_dynamic_partition_pruning.q | 2 +-
.../test/queries/clientpositive/subquery_in.q | 50 +-
.../queries/clientpositive/subquery_scalar.q | 49 +
ql/src/test/queries/clientpositive/sysdb.q | 12 +-
.../test/queries/clientpositive/timestamptz.q | 16 +-
.../test/queries/clientpositive/timestamptz_1.q | 4 +-
.../test/queries/clientpositive/timestamptz_2.q | 3 +-
.../clientpositive/truncate_column_buckets.q | 4 +-
.../queries/clientpositive/udf_stddev_samp.q | 9 +
.../test/queries/clientpositive/udf_var_samp.q | 9 +
.../test/queries/clientpositive/varchar_udf1.q | 4 +-
.../queries/clientpositive/vector_aggregate_9.q | 16 +-
.../clientpositive/vector_between_columns.q | 1 +
.../queries/clientpositive/vector_complex_all.q | 41 +
.../clientpositive/vector_groupby_cube1.q | 17 +-
.../vector_groupby_grouping_id1.q | 21 +
.../vector_groupby_grouping_id2.q | 52 +
.../vector_groupby_grouping_window.q | 1 +
.../clientpositive/vector_groupby_reduce.q | 73 +-
.../vector_outer_reference_windowed.q | 91 +
.../clientpositive/vector_ptf_part_simple.q | 240 +-
.../clientpositive/vector_tablesample_rows.q | 8 +-
.../test/queries/clientpositive/vector_udf1.q | 74 +-
.../queries/clientpositive/vector_windowing.q | 791 +
.../vector_windowing_expressions.q | 94 +
.../clientpositive/vector_windowing_gby.q | 21 +
.../clientpositive/vector_windowing_gby2.q | 48 +
.../vector_windowing_multipartitioning.q | 73 +
.../clientpositive/vector_windowing_navfn.q | 2 +
.../vector_windowing_order_null.q | 58 +
.../vector_windowing_range_multiorder.q | 68 +
.../clientpositive/vector_windowing_rank.q | 117 +
.../clientpositive/vector_windowing_streaming.q | 85 +
.../vector_windowing_windowspec.q | 70 +
.../vector_windowing_windowspec4.q | 37 +
.../queries/clientpositive/vectorization_0.q | 15 +-
.../queries/clientpositive/vectorization_1.q | 22 +
.../queries/clientpositive/vectorization_10.q | 24 +
.../queries/clientpositive/vectorization_11.q | 15 +
.../queries/clientpositive/vectorization_12.q | 32 +
.../queries/clientpositive/vectorization_13.q | 2 +-
.../queries/clientpositive/vectorization_14.q | 2 +-
.../queries/clientpositive/vectorization_15.q | 5 +-
.../queries/clientpositive/vectorization_16.q | 2 +-
.../queries/clientpositive/vectorization_17.q | 2 +-
.../queries/clientpositive/vectorization_2.q | 23 +
.../queries/clientpositive/vectorization_3.q | 25 +
.../queries/clientpositive/vectorization_4.q | 23 +
.../queries/clientpositive/vectorization_5.q | 20 +
.../queries/clientpositive/vectorization_6.q | 21 +
.../queries/clientpositive/vectorization_7.q | 2 +-
.../queries/clientpositive/vectorization_8.q | 2 +-
.../queries/clientpositive/vectorization_9.q | 2 +-
.../queries/clientpositive/vectorized_casts.q | 4 +-
.../clientpositive/vectorized_distinct_gby.q | 7 +-
.../vectorized_multi_output_select.q | 28 +
.../queries/clientpositive/vectorized_parquet.q | 4 +
.../clientpositive/vectorized_parquet_types.q | 1 +
.../queries/clientpositive/vectorized_ptf.q | 1 +
.../clientpositive/vectorized_timestamp.q | 27 +-
.../results/clientnegative/acid_overwrite.q.out | 19 -
...er_table_non_partitioned_table_cascade.q.out | 21 +
.../authorization_uri_export.q.out | 1 +
.../clientnegative/create_not_acid.q.out | 4 +-
.../clientnegative/delete_non_acid_table.q.out | 2 +-
.../results/clientnegative/dyn_part_max.q.out | 1 -
.../clientnegative/load_data_into_acid.q.out | 33 +
.../parquet_alter_part_table_drop_columns.q.out | 53 +
.../parquet_int96_alter_invalid_timezone.q.out | 13 -
.../parquet_int96_create_invalid_timezone.q.out | 5 -
.../repl_dump_requires_admin.q.out | 69 +
.../repl_load_requires_admin.q.out | 80 +
.../set_hiveconf_internal_variable0.q.out | 2 +-
.../set_hiveconf_internal_variable1.q.out | 2 +-
.../subquery_scalar_implicit_gby.q.out | 1 -
.../clientnegative/update_non_acid_table.q.out | 2 +-
.../clientpositive/acid_insert_overwrite.q.out | 395 +
.../clientpositive/acid_table_stats.q.out | 14 +-
.../clientpositive/alterColumnStats.q.out | 16 +-
.../clientpositive/alterColumnStatsPart.q.out | 6 +-
.../alter_partition_onto_nocurrent_db.q.out | 78 +
.../alter_partition_update_status.q.out | 30 +-
.../alter_table_column_stats.q.out | 672 +-
.../alter_table_update_status.q.out | 384 +-
..._table_update_status_disable_bitvector.q.out | 708 +
.../clientpositive/analyze_tbl_part.q.out | 18 +-
.../annotate_stats_deep_filters.q.out | 4 +-
.../clientpositive/annotate_stats_groupby.q.out | 10 +-
.../clientpositive/annotate_stats_join.q.out | 44 +-
.../annotate_stats_join_pkfk.q.out | 28 +-
.../clientpositive/annotate_stats_select.q.out | 4 +-
.../clientpositive/autoColumnStats_4.q.out | 16 +-
.../clientpositive/autoColumnStats_5.q.out | 50 +-
.../clientpositive/autoColumnStats_6.q.out | 6 +-
.../clientpositive/autoColumnStats_7.q.out | 12 +-
.../clientpositive/autoColumnStats_8.q.out | 22 +-
.../clientpositive/autoColumnStats_9.q.out | 32 +-
.../results/clientpositive/auto_join0.q.out | 109 +-
.../results/clientpositive/auto_join12.q.out | 22 +-
.../results/clientpositive/auto_join15.q.out | 47 +-
.../results/clientpositive/auto_join16.q.out | 16 +-
.../results/clientpositive/auto_join20.q.out | 94 +-
.../results/clientpositive/auto_join26.q.out | 8 +-
.../results/clientpositive/auto_join27.q.out | 8 +-
.../results/clientpositive/auto_join31.q.out | 286 +-
.../results/clientpositive/auto_join4.q.out | 6 +-
.../results/clientpositive/auto_join5.q.out | 6 +-
.../results/clientpositive/auto_join8.q.out | 6 +-
.../auto_join_without_localtask.q.out | 74 +-
.../results/clientpositive/avro_decimal.q.out | 8 +-
.../clientpositive/avro_decimal_native.q.out | 8 +-
.../materialized_view_create_rewrite.q.out | 8 +
.../clientpositive/beeline/smb_mapjoin_12.q.out | 75 +-
.../test/results/clientpositive/bitvector.q.out | 10 +
.../bucket_num_reducers_acid.q.out | 33 +
.../bucket_num_reducers_acid2.q.out | 44 +
.../bucketsortoptimize_insert_8.q.out | 342 +-
.../cbo_rp_annotate_stats_groupby.q.out | 10 +-
.../clientpositive/cbo_rp_auto_join0.q.out | 98 +-
.../clientpositive/cbo_rp_auto_join1.q.out | 18 +-
.../results/clientpositive/cbo_rp_join0.q.out | 12 +-
.../clientpositive/cbo_rp_outer_join_ppr.q.out | 44 +-
.../test/results/clientpositive/char_udf1.q.out | 10 +-
.../clientpositive/cmdwithcomments.q.out | 17 +-
.../clientpositive/colstats_all_nulls.q.out | 16 +-
...names_with_leading_and_trailing_spaces.q.out | 16 +-
.../column_pruner_multiple_children.q.out | 22 +-
.../clientpositive/columnstats_partlvl.q.out | 92 +-
.../clientpositive/columnstats_partlvl_dp.q.out | 84 +-
.../clientpositive/columnstats_quoting.q.out | 24 +-
.../clientpositive/columnstats_tbllvl.q.out | 144 +-
.../test/results/clientpositive/combine2.q.out | 6 +-
.../results/clientpositive/compustat_avro.q.out | 16 +-
.../clientpositive/compute_stats_date.q.out | 34 +-
.../clientpositive/compute_stats_decimal.q.out | Bin 1633 -> 1512 bytes
.../clientpositive/compute_stats_double.q.out | Bin 1539 -> 1443 bytes
.../compute_stats_empty_table.q.out | 6 +-
.../clientpositive/compute_stats_long.q.out | Bin 1498 -> 1376 bytes
.../clientpositive/compute_stats_string.q.out | Bin 1517 -> 1448 bytes
.../test/results/clientpositive/concat_op.q.out | 24 +-
.../confirm_initial_tbl_stats.q.out | 86 +-
.../test/results/clientpositive/constGby.q.out | 2 +-
.../clientpositive/constant_prop_2.q.out | 6 +-
.../clientpositive/constantfolding.q.out | 4 +-
.../clientpositive/constprog_partitioner.q.out | 10 +-
.../clientpositive/correlated_join_keys.q.out | 10 +-
.../clientpositive/correlationoptimizer10.q.out | 4 +-
.../clientpositive/correlationoptimizer11.q.out | 8 +-
.../clientpositive/correlationoptimizer12.q.out | 4 +-
.../clientpositive/correlationoptimizer13.q.out | 32 +-
.../clientpositive/correlationoptimizer15.q.out | 4 +-
.../clientpositive/correlationoptimizer7.q.out | 24 +-
.../clientpositive/correlationoptimizer8.q.out | 252 +-
.../clientpositive/correlationoptimizer9.q.out | 156 +-
.../clientpositive/count_dist_rewrite.q.out | 12 +-
.../results/clientpositive/create_view.q.out | 4 +-
.../clientpositive/cross_join_merge.q.out | 80 +-
.../results/clientpositive/ctas_colname.q.out | 4 +-
.../results/clientpositive/decimal_stats.q.out | 8 +-
.../results/clientpositive/decimal_udf.q.out | 24 +-
.../results/clientpositive/deleteAnalyze.q.out | 8 +-
.../clientpositive/describe_syntax.q.out | 24 +-
.../results/clientpositive/describe_table.q.out | 32 +-
ql/src/test/results/clientpositive/dfscmd.q.out | 1 +
.../display_colstats_tbllvl.q.out | 128 +-
.../clientpositive/distinct_windowing.q.out | 8 +-
.../distinct_windowing_no_cbo.q.out | 12 +-
.../results/clientpositive/druid_basic2.q.out | 103 +-
.../clientpositive/druid_intervals.q.out | 130 +-
.../clientpositive/druid_timeseries.q.out | 6 +-
.../results/clientpositive/druid_topn.q.out | 268 +-
.../clientpositive/dynamic_rdd_cache.q.out | 1431 -
.../dynpart_sort_optimization_acid.q.out | 1475 -
.../encrypted/encryption_move_tbl.q.out | 36 +-
.../results/clientpositive/except_all.q.out | 48 +-
.../exec_parallel_column_stats.q.out | 12 +-
.../clientpositive/explain_logical.q.out | 32 +-
.../explaindenpendencydiffengs.q.out | 52 +
.../extrapolate_part_stats_full.q.out | 6 +-
.../extrapolate_part_stats_partial.q.out | 20 +-
.../results/clientpositive/filter_aggr.q.out | 228 +-
.../results/clientpositive/filter_union.q.out | 593 +
.../test/results/clientpositive/fm-sketch.q.out | 323 +
.../test/results/clientpositive/fold_case.q.out | 14 +-
.../clientpositive/fouter_join_ppr.q.out | 84 +-
.../results/clientpositive/groupby4_map.q.out | 4 +-
.../clientpositive/groupby4_map_skew.q.out | 4 +-
.../results/clientpositive/groupby_cube1.q.out | 20 +-
.../groupby_distinct_samekey.q.out | 45 +-
.../groupby_grouping_window.q.out | 2 +-
.../clientpositive/groupby_position.q.out | 56 +-
.../clientpositive/groupby_rollup1.q.out | 12 +-
.../clientpositive/groupby_sort_11.q.out | 18 +-
.../clientpositive/groupby_sort_1_23.q.out | 254 +-
.../results/clientpositive/groupby_sort_2.q.out | 6 +-
.../results/clientpositive/groupby_sort_3.q.out | 12 +-
.../results/clientpositive/groupby_sort_4.q.out | 12 +-
.../results/clientpositive/groupby_sort_5.q.out | 18 +-
.../results/clientpositive/groupby_sort_6.q.out | 20 +-
.../results/clientpositive/groupby_sort_7.q.out | 6 +-
.../results/clientpositive/groupby_sort_9.q.out | 6 +-
.../clientpositive/groupby_sort_skew_1_23.q.out | 254 +-
.../clientpositive/groupby_sort_test_1.q.out | 6 +-
ql/src/test/results/clientpositive/hll.q.out | 323 +
.../identity_project_remove_skip.q.out | 189 +-
.../clientpositive/index_auto_mult_tables.q.out | 52 +-
.../index_auto_mult_tables_compact.q.out | 52 +-
.../clientpositive/infer_bucket_sort.q.out | 4 +-
.../infer_bucket_sort_grouping_operators.q.out | 18 +-
.../results/clientpositive/innerjoin1.q.out | 214 +
.../test/results/clientpositive/input20.q.out | 21 +-
.../test/results/clientpositive/input30.q.out | 6 +-
.../test/results/clientpositive/input31.q.out | 4 +-
.../test/results/clientpositive/input32.q.out | 4 +-
.../test/results/clientpositive/input33.q.out | 21 +-
.../test/results/clientpositive/input39.q.out | 2 +-
.../results/clientpositive/input3_limit.q.out | 44 +-
.../test/results/clientpositive/input41.q.out | 2 +-
.../clientpositive/insert_orig_table.q.out | 68 +-
.../insert_overwrite_directory.q.out | 8 +-
.../insert_values_orig_table.q.out | 68 +-
.../insert_values_orig_table_use_metadata.q.out | 116 +-
ql/src/test/results/clientpositive/join12.q.out | 30 +-
ql/src/test/results/clientpositive/join16.q.out | 22 +-
ql/src/test/results/clientpositive/join29.q.out | 48 +-
ql/src/test/results/clientpositive/join30.q.out | 8 +-
ql/src/test/results/clientpositive/join31.q.out | 6 +-
ql/src/test/results/clientpositive/join32.q.out | 80 +-
ql/src/test/results/clientpositive/join33.q.out | 80 +-
ql/src/test/results/clientpositive/join35.q.out | 64 +-
ql/src/test/results/clientpositive/join38.q.out | 28 +-
ql/src/test/results/clientpositive/join4.q.out | 8 +-
ql/src/test/results/clientpositive/join40.q.out | 6 +-
ql/src/test/results/clientpositive/join47.q.out | 1715 +
ql/src/test/results/clientpositive/join5.q.out | 8 +-
ql/src/test/results/clientpositive/join8.q.out | 8 +-
.../clientpositive/join_alt_syntax.q.out | 272 +-
.../clientpositive/join_cond_pushdown_2.q.out | 112 +-
.../clientpositive/join_cond_pushdown_4.q.out | 112 +-
.../clientpositive/join_filters_overlap.q.out | 4 +-
.../results/clientpositive/join_parse.q.out | 102 +-
.../limit_pushdown_negative.q.out | 96 +-
.../list_bucket_query_oneskew_2.q.out | 10 +-
.../llap/acid_bucket_pruning.q.out | 30 +-
.../clientpositive/llap/acid_no_buckets.q.out | 1976 +
.../llap/authorization_view_8.q.out | 69 +
.../clientpositive/llap/autoColumnStats_2.q.out | 64 +-
.../clientpositive/llap/auto_join0.q.out | 51 +-
.../clientpositive/llap/auto_join1.q.out | 6 +-
.../clientpositive/llap/auto_join21.q.out | 10 +-
.../clientpositive/llap/auto_join29.q.out | 90 +-
.../clientpositive/llap/auto_join30.q.out | 630 +-
.../llap/auto_smb_mapjoin_14.q.out | 44 +-
.../llap/auto_sortmerge_join_9.q.out | 234 +-
.../clientpositive/llap/bucket_groupby.q.out | 72 +-
.../llap/bucket_map_join_tez1.q.out | 7 -
.../llap/bucket_map_join_tez2.q.out | 34 +-
.../results/clientpositive/llap/cluster.q.out | 40 +-
...names_with_leading_and_trailing_spaces.q.out | 16 +-
.../llap/column_table_stats.q.out | 68 +-
.../llap/column_table_stats_orc.q.out | 50 +-
.../llap/columnstats_part_coltype.q.out | 126 +-
.../llap/correlationoptimizer1.q.out | 376 +-
.../llap/correlationoptimizer2.q.out | 186 +-
.../llap/correlationoptimizer3.q.out | 296 +-
.../llap/correlationoptimizer4.q.out | 220 +-
.../llap/correlationoptimizer6.q.out | 532 +-
.../results/clientpositive/llap/count.q.out | 124 +-
.../llap/count_dist_rewrite.q.out | 66 +-
.../clientpositive/llap/cross_join.q.out | 8 +-
.../clientpositive/llap/deleteAnalyze.q.out | 8 +-
.../llap/dynamic_partition_pruning.q.out | 317 +-
.../llap/dynamic_semijoin_reduction.q.out | 863 +-
.../llap/dynamic_semijoin_reduction_3.q.out | 4 +-
.../llap/dynamic_semijoin_reduction_sw.q.out | 518 +
.../llap/dynamic_semijoin_user_level.q.out | 172 +-
.../llap/dynpart_sort_optimization2.q.out | 20 +-
.../clientpositive/llap/except_distinct.q.out | 52 +-
.../clientpositive/llap/explainuser_1.q.out | 1505 +-
.../clientpositive/llap/explainuser_2.q.out | 931 +-
.../clientpositive/llap/explainuser_4.q.out | 14 +-
.../extrapolate_part_stats_partial_ndv.q.out | 132 +-
.../clientpositive/llap/filter_union.q.out | 539 +
.../results/clientpositive/llap/groupby1.q.out | 6 +-
.../results/clientpositive/llap/groupby2.q.out | 6 +-
.../llap/groupby_resolution.q.out | 78 +-
.../results/clientpositive/llap/having.q.out | 66 +-
.../llap/hybridgrace_hashjoin_1.q.out | 12 +-
.../llap/hybridgrace_hashjoin_2.q.out | 24 +-
.../llap/identity_project_remove_skip.q.out | 71 +-
.../clientpositive/llap/insert_orig_table.q.out | 68 +-
.../clientpositive/llap/intersect_all.q.out | 40 +-
.../llap/intersect_distinct.q.out | 40 +-
.../clientpositive/llap/intersect_merge.q.out | 204 +-
.../clientpositive/llap/jdbc_handler.q.out | 32 +-
.../results/clientpositive/llap/join1.q.out | 6 +-
.../clientpositive/llap/join32_lessSize.q.out | 175 +-
.../llap/join_max_hashtable.q.out | 222 +-
.../llap/limit_join_transpose.q.out | 214 +-
.../clientpositive/llap/limit_pushdown.q.out | 68 +-
.../clientpositive/llap/limit_pushdown3.q.out | 64 +-
.../results/clientpositive/llap/lineage2.q.out | 4 +-
.../results/clientpositive/llap/lineage3.q.out | 4 +-
.../results/clientpositive/llap/llap_smb.q.out | 359 +
.../clientpositive/llap/llap_stats.q.out | 16 +-
.../llap/llap_vector_nohybridgrace.q.out | 12 +-
.../clientpositive/llap/llapdecider.q.out | 88 +-
.../results/clientpositive/llap/merge1.q.out | 16 +-
.../results/clientpositive/llap/merge2.q.out | 12 +-
.../results/clientpositive/llap/mergejoin.q.out | 16 +-
.../llap/metadata_only_queries.q.out | 112 +-
.../test/results/clientpositive/llap/mrr.q.out | 153 +-
.../clientpositive/llap/multiMapJoin2.q.out | 255 +-
.../clientpositive/llap/offset_limit.q.out | 10 +-
.../llap/offset_limit_ppd_optimizer.q.out | 58 +-
.../clientpositive/llap/orc_create.q.out | 2 +-
.../llap/orc_merge_incompat_schema.q.out | 161 +
.../orc_merge_incompat_writer_version.q.out | 108 +
.../clientpositive/llap/orc_ppd_basic.q.out | 234 +-
.../results/clientpositive/llap/parallel.q.out | 2 +-
.../clientpositive/llap/parallel_colstats.q.out | 26 +-
.../llap/parquet_predicate_pushdown.q.out | 18 +-
.../llap/parquet_types_vectorization.q.out | 849 +
.../clientpositive/llap/partialdhj.q.out | 460 +
.../llap/partition_shared_scan.q.out | 7 -
.../test/results/clientpositive/llap/ptf.q.out | 154 +-
.../clientpositive/llap/ptf_streaming.q.out | 96 +-
.../llap/reduce_deduplicate_extended.q.out | 74 +-
.../schema_evol_orc_vec_part_all_complex.q.out | 72 +-
.../schema_evol_text_vec_part_all_complex.q.out | 72 +-
...hema_evol_text_vecrow_part_all_complex.q.out | 72 +-
.../clientpositive/llap/semijoin_hint.q.out | 175 +-
.../results/clientpositive/llap/skewjoin.q.out | 12 +-
.../clientpositive/llap/skewjoinopt15.q.out | 4 +-
.../clientpositive/llap/smb_mapjoin_14.q.out | 54 +-
.../clientpositive/llap/smb_mapjoin_15.q.out | 4 +-
.../clientpositive/llap/stats_only_null.q.out | 6 +-
.../clientpositive/llap/subquery_exists.q.out | 22 +-
.../clientpositive/llap/subquery_in.q.out | 1015 +-
.../clientpositive/llap/subquery_multi.q.out | 531 +-
.../clientpositive/llap/subquery_notin.q.out | 740 +-
.../clientpositive/llap/subquery_null_agg.q.out | 55 +-
.../clientpositive/llap/subquery_scalar.q.out | 2227 +-
.../clientpositive/llap/subquery_select.q.out | 244 +-
.../clientpositive/llap/subquery_views.q.out | 111 +-
.../results/clientpositive/llap/sysdb.q.out | 252 +-
.../llap/table_access_keys_stats.q.out | 36 +-
.../results/clientpositive/llap/tez_dml.q.out | 12 +-
.../llap/tez_dynpart_hashjoin_1.q.out | 24 +-
.../llap/tez_dynpart_hashjoin_2.q.out | 24 +-
.../llap/tez_dynpart_hashjoin_3.q.out | 4 +-
.../clientpositive/llap/tez_join_hash.q.out | 20 +-
.../clientpositive/llap/tez_join_tests.q.out | 37 +-
.../clientpositive/llap/tez_joins_explain.q.out | 37 +-
.../clientpositive/llap/tez_smb_empty.q.out | 16 +-
.../clientpositive/llap/tez_smb_main.q.out | 4 +-
.../results/clientpositive/llap/tez_union.q.out | 64 +-
.../clientpositive/llap/tez_union2.q.out | 16 +-
.../llap/tez_union_group_by.q.out | 2 +-
.../llap/tez_union_multiinsert.q.out | 68 +-
.../llap/tez_vector_dynpart_hashjoin_1.q.out | 24 +-
.../llap/tez_vector_dynpart_hashjoin_2.q.out | 24 +-
.../results/clientpositive/llap/union2.q.out | 4 +-
.../results/clientpositive/llap/union4.q.out | 6 +-
.../results/clientpositive/llap/union5.q.out | 4 +-
.../results/clientpositive/llap/union6.q.out | 4 +-
.../results/clientpositive/llap/union7.q.out | 20 +-
.../results/clientpositive/llap/union9.q.out | 6 +-
.../clientpositive/llap/unionDistinct_1.q.out | 283 +-
.../clientpositive/llap/union_remove_26.q.out | 54 +-
.../clientpositive/llap/union_top_level.q.out | 30 +-
.../clientpositive/llap/varchar_udf1.q.out | 10 +-
.../llap/vector_adaptor_usage_mode.q.out | 43 +-
.../llap/vector_aggregate_9.q.out | 311 +-
.../llap/vector_auto_smb_mapjoin_14.q.out | 104 +-
.../clientpositive/llap/vector_between_in.q.out | 44 +-
.../llap/vector_binary_join_groupby.q.out | 8 +
.../llap/vector_cast_constant.q.out | 34 +-
.../clientpositive/llap/vector_char_2.q.out | 8 +
.../clientpositive/llap/vector_coalesce_2.q.out | 8 +
.../llap/vector_complex_all.q.out | 1209 +-
.../llap/vector_complex_join.q.out | 77 +-
.../clientpositive/llap/vector_count.q.out | 70 +-
.../llap/vector_count_distinct.q.out | 8 +
.../clientpositive/llap/vector_date_1.q.out | 2 +-
.../llap/vector_decimal_aggregate.q.out | 45 +-
.../llap/vector_decimal_precision.q.out | 32 +-
.../llap/vector_decimal_round.q.out | 44 +-
.../llap/vector_decimal_udf.q.out | 6 +-
.../clientpositive/llap/vector_distinct_2.q.out | 4 +
.../llap/vector_empty_where.q.out | 32 +
.../clientpositive/llap/vector_groupby4.q.out | 4 +
.../clientpositive/llap/vector_groupby6.q.out | 4 +
.../clientpositive/llap/vector_groupby_3.q.out | 4 +
.../llap/vector_groupby_cube1.q.out | 196 +-
.../llap/vector_groupby_grouping_id1.q.out | 800 +
.../llap/vector_groupby_grouping_id2.q.out | 2117 +
.../llap/vector_groupby_grouping_id3.q.out | 8 +
.../llap/vector_groupby_grouping_sets3.q.out | 8 +-
.../llap/vector_groupby_grouping_sets4.q.out | 27 -
.../vector_groupby_grouping_sets_grouping.q.out | 2 +-
.../llap/vector_groupby_grouping_window.q.out | 4 +-
.../llap/vector_groupby_mapjoin.q.out | 22 +-
.../llap/vector_groupby_reduce.q.out | 2568 +-
.../llap/vector_groupby_rollup1.q.out | 12 +-
.../llap/vector_grouping_sets.q.out | 8 +
.../llap/vector_include_no_sel.q.out | 4 +
.../clientpositive/llap/vector_inner_join.q.out | 2 +
.../llap/vector_interval_mapjoin.q.out | 8 +-
.../clientpositive/llap/vector_join30.q.out | 1170 +-
.../llap/vector_left_outer_join.q.out | 4 +-
.../llap/vector_leftsemi_mapjoin.q.out | 168 +
.../llap/vector_mapjoin_reduce.q.out | 52 +-
.../llap/vector_mr_diff_schema_alias.q.out | 34 +-
.../llap/vector_null_projection.q.out | 8 +-
.../llap/vector_number_compare_projection.q.out | 186 +-
.../clientpositive/llap/vector_nvl.q.out | 2 +-
.../clientpositive/llap/vector_orderby_5.q.out | 4 +
.../llap/vector_outer_join1.q.out | 16 +-
.../llap/vector_outer_join2.q.out | 8 +-
.../llap/vector_outer_reference_windowed.q.out | 1435 +
.../llap/vector_partition_diff_num_cols.q.out | 20 +
.../llap/vector_partitioned_date_time.q.out | 40 +-
.../llap/vector_ptf_part_simple.q.out | 3898 +-
.../llap/vector_reduce_groupby_decimal.q.out | 4 +
.../llap/vector_string_concat.q.out | 4 +
.../llap/vector_tablesample_rows.q.out | 93 +-
.../clientpositive/llap/vector_udf1.q.out | 1137 +-
.../llap/vector_when_case_null.q.out | 12 +-
.../clientpositive/llap/vector_windowing.q.out | 9768 +
.../llap/vector_windowing_expressions.q.out | 2022 +
.../llap/vector_windowing_gby.q.out | 314 +
.../llap/vector_windowing_gby2.q.out | 1158 +
.../vector_windowing_multipartitioning.q.out | 11587 +
.../llap/vector_windowing_navfn.q.out | 218 +-
.../llap/vector_windowing_order_null.q.out | 1232 +
.../vector_windowing_range_multiorder.q.out | 12584 ++
.../llap/vector_windowing_rank.q.out | 1860 +
.../llap/vector_windowing_streaming.q.out | 1036 +
.../llap/vector_windowing_windowspec.q.out | 2374 +
.../llap/vector_windowing_windowspec4.q.out | 223 +
.../clientpositive/llap/vectorization_0.q.out | 281 +-
.../clientpositive/llap/vectorization_1.q.out | 175 +
.../clientpositive/llap/vectorization_10.q.out | 118 +
.../clientpositive/llap/vectorization_11.q.out | 100 +
.../clientpositive/llap/vectorization_12.q.out | 240 +
.../clientpositive/llap/vectorization_13.q.out | 100 +-
.../clientpositive/llap/vectorization_14.q.out | 86 +-
.../clientpositive/llap/vectorization_15.q.out | 155 +-
.../clientpositive/llap/vectorization_16.q.out | 68 +-
.../clientpositive/llap/vectorization_17.q.out | 41 +-
.../clientpositive/llap/vectorization_2.q.out | 179 +
.../clientpositive/llap/vectorization_3.q.out | 184 +
.../clientpositive/llap/vectorization_4.q.out | 178 +
.../clientpositive/llap/vectorization_5.q.out | 173 +
.../clientpositive/llap/vectorization_6.q.out | 112 +
.../clientpositive/llap/vectorization_7.q.out | 18 +-
.../clientpositive/llap/vectorization_8.q.out | 34 +-
.../clientpositive/llap/vectorization_9.q.out | 68 +-
.../llap/vectorization_limit.q.out | 83 +-
.../llap/vectorization_pushdown.q.out | 10 +-
.../llap/vectorization_short_regress.q.out | 376 +-
.../llap/vectorized_bucketmapjoin1.q.out | 21 +-
.../clientpositive/llap/vectorized_case.q.out | 20 +-
.../clientpositive/llap/vectorized_casts.q.out | 89 +-
.../llap/vectorized_date_funcs.q.out | 4 +
.../llap/vectorized_distinct_gby.q.out | 150 +-
.../vectorized_dynamic_partition_pruning.q.out | 340 +-
.../vectorized_dynamic_semijoin_reduction.q.out | 60 +-
...vectorized_dynamic_semijoin_reduction2.q.out | 30 +-
.../llap/vectorized_mapjoin.q.out | 36 +-
.../llap/vectorized_mapjoin2.q.out | 8 +-
.../llap/vectorized_multi_output_select.q.out | 201 +
.../llap/vectorized_nested_mapjoin.q.out | 6 +-
.../llap/vectorized_parquet.q.out | 28 +-
.../llap/vectorized_parquet_types.q.out | 36 +-
.../clientpositive/llap/vectorized_ptf.q.out | 298 +-
.../llap/vectorized_shufflejoin.q.out | 26 +-
.../llap/vectorized_timestamp.q.out | 630 +-
.../llap/vectorized_timestamp_funcs.q.out | 70 +-
.../results/clientpositive/llap/windowing.q.out | 2 +-
.../clientpositive/llap/windowing_gby.q.out | 4 +-
.../llap/windowing_windowspec.q.out | 955 +
.../results/clientpositive/localtimezone.q.out | 558 +
.../clientpositive/louter_join_ppr.q.out | 84 +-
.../test/results/clientpositive/mapjoin47.q.out | 1790 +
.../test/results/clientpositive/masking_4.q.out | 16 +-
.../materialized_view_create.q.out | 40 +
.../materialized_view_create_rewrite.q.out | 8 +
ql/src/test/results/clientpositive/merge1.q.out | 6 +-
ql/src/test/results/clientpositive/merge2.q.out | 6 +-
.../clientpositive/metadata_only_queries.q.out | 112 +-
ql/src/test/results/clientpositive/mm_all.q.out | 296 -
.../results/clientpositive/mm_loaddata.q.out | 296 +
.../clientpositive/multi_insert_gby2.q.out | 40 +-
.../clientpositive/multi_insert_gby3.q.out | 189 +-
.../clientpositive/nested_column_pruning.q.out | 42 +-
.../results/clientpositive/notable_alias1.q.out | 24 +-
.../results/clientpositive/notable_alias2.q.out | 24 +-
.../test/results/clientpositive/nullgroup.q.out | 8 +-
.../results/clientpositive/nullgroup2.q.out | 76 +-
.../results/clientpositive/nullgroup3.q.out | 8 +-
.../results/clientpositive/nullgroup4.q.out | 26 +-
.../nullgroup4_multi_distinct.q.out | 12 +-
.../results/clientpositive/orc_create.q.out | 2 +-
.../clientpositive/orc_empty_table.q.out | 68 +
.../orc_merge_incompat_schema.q.out | 161 +
.../orc_merge_incompat_writer_version.q.out | 108 +
.../results/clientpositive/outer_join_ppr.q.out | 40 +-
.../outer_reference_windowed.q.out | 10 +-
.../clientpositive/parallel_colstats.q.out | 24 +-
.../clientpositive/parquet_analyze.q.out | 4 +-
.../parquet_int96_timestamp.q.out | 191 +-
.../parquet_mixed_partition_formats.q.out | 6 +-
.../clientpositive/parquet_no_row_serde.q.out | 190 +
.../parquet_predicate_pushdown_2.q.out | 38 +
.../parquet_timestamp_conversion.q.out | 68 -
.../clientpositive/partial_column_stats.q.out | 20 +-
.../clientpositive/partition_boolexpr.q.out | 4 +-
.../partition_coltype_literals.q.out | 44 +-
ql/src/test/results/clientpositive/pcs.q.out | 2 +-
.../results/clientpositive/perf/query1.q.out | 40 +-
.../results/clientpositive/perf/query10.q.out | 52 +-
.../results/clientpositive/perf/query11.q.out | 351 +
.../results/clientpositive/perf/query14.q.out | 1876 +-
.../results/clientpositive/perf/query16.q.out | 265 +-
.../results/clientpositive/perf/query17.q.out | 236 +-
.../results/clientpositive/perf/query2.q.out | 22 +-
.../results/clientpositive/perf/query23.q.out | 180 +-
.../results/clientpositive/perf/query24.q.out | 162 +-
.../results/clientpositive/perf/query25.q.out | 232 +-
.../results/clientpositive/perf/query28.q.out | 184 +-
.../results/clientpositive/perf/query29.q.out | 232 +-
.../results/clientpositive/perf/query30.q.out | 102 +-
.../results/clientpositive/perf/query31.q.out | 90 +-
.../results/clientpositive/perf/query32.q.out | 18 +-
.../results/clientpositive/perf/query33.q.out | 178 +-
.../results/clientpositive/perf/query35.q.out | 32 +-
.../results/clientpositive/perf/query38.q.out | 270 +-
.../results/clientpositive/perf/query39.q.out | 30 +-
.../results/clientpositive/perf/query4.q.out | 1118 +-
.../results/clientpositive/perf/query44.q.out | 29 +-
.../results/clientpositive/perf/query45.q.out | 6 +-
.../results/clientpositive/perf/query46.q.out | 6 +-
.../results/clientpositive/perf/query47.q.out | 222 +-
.../results/clientpositive/perf/query49.q.out | 22 +-
.../results/clientpositive/perf/query5.q.out | 122 +-
.../results/clientpositive/perf/query50.q.out | 72 +-
.../results/clientpositive/perf/query51.q.out | 6 +-
.../results/clientpositive/perf/query54.q.out | 458 +-
.../results/clientpositive/perf/query56.q.out | 178 +-
.../results/clientpositive/perf/query57.q.out | 222 +-
.../results/clientpositive/perf/query58.q.out | 96 +-
.../results/clientpositive/perf/query59.q.out | 20 +-
.../results/clientpositive/perf/query6.q.out | 306 +-
.../results/clientpositive/perf/query60.q.out | 178 +-
.../results/clientpositive/perf/query61.q.out | 30 +-
.../results/clientpositive/perf/query64.q.out | 734 +-
.../results/clientpositive/perf/query65.q.out | 6 +-
.../results/clientpositive/perf/query66.q.out | 40 +-
.../results/clientpositive/perf/query68.q.out | 6 +-
.../results/clientpositive/perf/query69.q.out | 32 +-
.../results/clientpositive/perf/query70.q.out | 22 +-
.../results/clientpositive/perf/query71.q.out | 80 +-
.../results/clientpositive/perf/query72.q.out | 270 +-
.../results/clientpositive/perf/query74.q.out | 544 +-
.../results/clientpositive/perf/query75.q.out | 110 +-
.../results/clientpositive/perf/query76.q.out | 84 +-
.../results/clientpositive/perf/query77.q.out | 188 +-
.../results/clientpositive/perf/query78.q.out | 104 +-
.../results/clientpositive/perf/query8.q.out | 10 +-
.../results/clientpositive/perf/query80.q.out | 172 +-
.../results/clientpositive/perf/query81.q.out | 104 +-
.../results/clientpositive/perf/query83.q.out | 311 +-
.../results/clientpositive/perf/query85.q.out | 148 +-
.../results/clientpositive/perf/query87.q.out | 248 +-
.../results/clientpositive/perf/query88.q.out | 138 +-
.../results/clientpositive/perf/query9.q.out | 90 +-
.../results/clientpositive/perf/query90.q.out | 30 +-
.../results/clientpositive/perf/query92.q.out | 18 +-
.../results/clientpositive/perf/query94.q.out | 265 +-
.../results/clientpositive/perf/query95.q.out | 80 +-
.../results/clientpositive/perf/query97.q.out | 16 +-
.../test/results/clientpositive/plan_json.q.out | 2 +-
ql/src/test/results/clientpositive/ppd2.q.out | 52 +-
.../test/results/clientpositive/ppd_gby.q.out | 32 +-
.../test/results/clientpositive/ppd_gby2.q.out | 44 +-
.../results/clientpositive/ppd_gby_join.q.out | 64 +-
.../test/results/clientpositive/ppd_join.q.out | 48 +-
.../test/results/clientpositive/ppd_join4.q.out | 23 +-
.../clientpositive/ppd_outer_join1.q.out | 40 +-
.../clientpositive/ppd_outer_join2.q.out | 40 +-
.../clientpositive/ppd_outer_join3.q.out | 40 +-
.../clientpositive/ppd_outer_join4.q.out | 60 +-
.../test/results/clientpositive/ppd_union.q.out | 82 +-
ql/src/test/results/clientpositive/ppd_vc.q.out | 18 +-
.../results/clientpositive/ppd_windowing1.q.out | 66 +-
.../results/clientpositive/ptfgroupbyjoin.q.out | 2 +-
.../results/clientpositive/quotedid_basic.q.out | 4 +-
.../clientpositive/rcfile_null_value.q.out | 8 +-
.../reduceSinkDeDuplication_pRS_key_empty.q.out | Bin 10132 -> 10596 bytes
.../reduce_deduplicate_extended2.q.out | 89 +-
.../clientpositive/remove_exprs_stats.q.out | 12 +-
.../rename_external_partition_location.q.out | 24 +-
.../rename_table_update_column_stats.q.out | 96 +-
.../clientpositive/router_join_ppr.q.out | 84 +-
.../test/results/clientpositive/row__id.q.out | 18 +-
.../test/results/clientpositive/semijoin2.q.out | 4 +-
.../test/results/clientpositive/semijoin4.q.out | 4 +-
.../test/results/clientpositive/semijoin5.q.out | 8 +-
.../set_processor_namespaces.q.out | 2 +
.../results/clientpositive/setop_subq.q.out | 36 +-
.../show_create_table_delimited.q.out | 2 +-
.../clientpositive/skewjoin_mapjoin1.q.out | 16 +-
.../clientpositive/skewjoin_mapjoin10.q.out | 16 +-
.../clientpositive/skewjoin_mapjoin5.q.out | 24 +-
.../results/clientpositive/skewjoinopt1.q.out | 8 +-
.../results/clientpositive/skewjoinopt2.q.out | 8 +-
.../results/clientpositive/skewjoinopt9.q.out | 24 +-
.../results/clientpositive/smb_mapjoin_12.q.out | 75 +-
.../results/clientpositive/smb_mapjoin_20.q.out | 1060 +-
.../results/clientpositive/smb_mapjoin_47.q.out | 1542 +
.../spark/annotate_stats_join.q.out | 44 +-
.../clientpositive/spark/auto_join0.q.out | 43 +-
.../clientpositive/spark/auto_join12.q.out | 22 +-
.../clientpositive/spark/auto_join15.q.out | 35 +-
.../clientpositive/spark/auto_join16.q.out | 16 +-
.../clientpositive/spark/auto_join20.q.out | 62 +-
.../clientpositive/spark/auto_join26.q.out | 4 +-
.../clientpositive/spark/auto_join27.q.out | 2 +-
.../clientpositive/spark/auto_join30.q.out | 793 +-
.../clientpositive/spark/auto_join31.q.out | 116 +-
.../clientpositive/spark/auto_join4.q.out | 6 +-
.../clientpositive/spark/auto_join5.q.out | 6 +-
.../clientpositive/spark/auto_join8.q.out | 6 +-
.../spark/auto_join_reordering_values.q.out | 10 +-
.../spark/auto_join_without_localtask.q.out | 28 +-
.../spark/auto_smb_mapjoin_14.q.out | 24 +-
.../spark/auto_sortmerge_join_1.q.out | 6 +-
.../spark/auto_sortmerge_join_12.q.out | 10 +-
.../spark/auto_sortmerge_join_3.q.out | 6 +-
.../spark/auto_sortmerge_join_4.q.out | 6 +-
.../spark/auto_sortmerge_join_5.q.out | 4 +-
.../spark/auto_sortmerge_join_7.q.out | 8 +-
.../spark/auto_sortmerge_join_8.q.out | 8 +-
.../spark/auto_sortmerge_join_9.q.out | 66 +-
.../spark/avro_decimal_native.q.out | 8 +-
.../spark/bucket_map_join_spark1.q.out | 8 +-
.../spark/bucket_map_join_spark2.q.out | 8 +-
.../spark/bucket_map_join_spark3.q.out | 8 +-
.../spark/bucket_map_join_spark4.q.out | 12 +-
.../spark/bucket_map_join_tez2.q.out | 28 +-
.../clientpositive/spark/bucketmapjoin1.q.out | 8 +-
.../clientpositive/spark/bucketmapjoin2.q.out | 14 +-
.../clientpositive/spark/bucketmapjoin3.q.out | 8 +-
.../clientpositive/spark/bucketmapjoin4.q.out | 8 +-
.../spark/constprog_partitioner.q.out | 10 +-
.../spark/constprog_semijoin.q.out | 20 +-
.../results/clientpositive/spark/count.q.out | 124 +-
.../spark/dynamic_rdd_cache.q.out | 75 +-
.../spark/explaindenpendencydiffengs.q.out | 52 +
.../spark/filter_join_breaktask.q.out | 6 +-
.../results/clientpositive/spark/groupby3.q.out | 2 +-
.../clientpositive/spark/groupby4_map.q.out | 4 +-
.../spark/groupby4_map_skew.q.out | 4 +-
.../clientpositive/spark/groupby_cube1.q.out | 20 +-
.../clientpositive/spark/groupby_map_ppr.q.out | 4 +-
.../spark/groupby_map_ppr_multi_distinct.q.out | 4 +-
.../clientpositive/spark/groupby_position.q.out | 62 +-
.../clientpositive/spark/groupby_ppr.q.out | 4 +-
.../spark/groupby_ppr_multi_distinct.q.out | 4 +-
.../spark/groupby_resolution.q.out | 2 +-
.../clientpositive/spark/groupby_rollup1.q.out | 12 +-
.../spark/groupby_sort_1_23.q.out | 240 +-
.../spark/groupby_sort_skew_1_23.q.out | 240 +-
.../spark/identity_project_remove_skip.q.out | 70 +-
.../clientpositive/spark/index_bitmap3.q.out | 4 +-
.../spark/index_bitmap_auto.q.out | 4 +-
.../spark/infer_bucket_sort_map_operators.q.out | 8 +-
.../infer_bucket_sort_reducers_power_two.q.out | 2 +-
.../results/clientpositive/spark/join12.q.out | 30 +-
.../results/clientpositive/spark/join16.q.out | 22 +-
.../results/clientpositive/spark/join17.q.out | 4 +-
.../results/clientpositive/spark/join26.q.out | 6 +-
.../results/clientpositive/spark/join29.q.out | 48 +-
.../results/clientpositive/spark/join30.q.out | 4 +-
.../results/clientpositive/spark/join31.q.out | 2 +-
.../results/clientpositive/spark/join32.q.out | 84 +-
.../clientpositive/spark/join32_lessSize.q.out | 104 +-
.../results/clientpositive/spark/join33.q.out | 84 +-
.../results/clientpositive/spark/join34.q.out | 6 +-
.../results/clientpositive/spark/join35.q.out | 66 +-
.../results/clientpositive/spark/join38.q.out | 24 +-
.../results/clientpositive/spark/join4.q.out | 8 +-
.../results/clientpositive/spark/join5.q.out | 8 +-
.../results/clientpositive/spark/join8.q.out | 8 +-
.../results/clientpositive/spark/join9.q.out | 4 +-
.../clientpositive/spark/join_alt_syntax.q.out | 220 +-
.../spark/join_cond_pushdown_2.q.out | 92 +-
.../spark/join_cond_pushdown_4.q.out | 92 +-
.../spark/join_filters_overlap.q.out | 38 +-
.../clientpositive/spark/limit_pushdown.q.out | 72 +-
.../clientpositive/spark/louter_join_ppr.q.out | 108 +-
.../clientpositive/spark/mapjoin_mapjoin.q.out | 12 +-
.../results/clientpositive/spark/merge1.q.out | 6 +-
.../results/clientpositive/spark/merge2.q.out | 6 +-
.../spark/metadata_only_queries.q.out | 112 +-
.../spark/multi_insert_gby2.q.out | 20 +-
.../spark/multi_insert_gby3.q.out | 126 +-
.../clientpositive/spark/nullgroup.q.out | 8 +-
.../clientpositive/spark/nullgroup2.q.out | 76 +-
.../clientpositive/spark/nullgroup4.q.out | 26 +-
.../spark/nullgroup4_multi_distinct.q.out | 12 +-
.../spark/optimize_nullscan.q.out | 58 +-
.../clientpositive/spark/outer_join_ppr.q.out | 52 +-
.../spark/parquet_int96_timestamp.q.out | 718 -
.../test/results/clientpositive/spark/pcr.q.out | 20 +-
.../clientpositive/spark/ppd_gby_join.q.out | 64 +-
.../results/clientpositive/spark/ppd_join.q.out | 48 +-
.../clientpositive/spark/ppd_join_filter.q.out | 16 +-
.../clientpositive/spark/ppd_outer_join1.q.out | 40 +-
.../clientpositive/spark/ppd_outer_join2.q.out | 40 +-
.../clientpositive/spark/ppd_outer_join3.q.out | 40 +-
.../clientpositive/spark/ppd_outer_join4.q.out | 60 +-
.../test/results/clientpositive/spark/ptf.q.out | 114 +-
.../clientpositive/spark/ptf_streaming.q.out | 62 +-
.../clientpositive/spark/router_join_ppr.q.out | 108 +-
.../clientpositive/spark/skewjoinopt1.q.out | 8 +-
.../clientpositive/spark/skewjoinopt15.q.out | 8 +-
.../clientpositive/spark/skewjoinopt2.q.out | 8 +-
.../clientpositive/spark/skewjoinopt9.q.out | 24 +-
.../clientpositive/spark/smb_mapjoin_14.q.out | 54 +-
.../clientpositive/spark/smb_mapjoin_15.q.out | 20 +-
.../clientpositive/spark/smb_mapjoin_20.q.out | 1063 +-
.../spark/spark_constprog_dpp.q.out | 138 +
.../spark/spark_dynamic_partition_pruning.q.out | 3343 +-
.../spark_dynamic_partition_pruning_2.q.out | 213 +-
.../spark_dynamic_partition_pruning_3.q.out | 1791 +
...dynamic_partition_pruning_mapjoin_only.q.out | 492 +
.../spark/spark_explain_groupbyshuffle.q.out | 116 +
.../spark/spark_explainuser_1.q.out | 1106 +-
.../spark_multi_insert_parallel_orderby.q.out | 2013 +
.../spark/spark_union_merge.q.out | 564 +
.../spark/spark_use_op_stats.q.out | 46 +-
.../spark/spark_use_ts_stats_for_mapjoin.q.out | 10 +-
.../results/clientpositive/spark/stats1.q.out | 4 +-
.../clientpositive/spark/stats_only_null.q.out | 6 +-
.../clientpositive/spark/subquery_exists.q.out | 10 +-
.../clientpositive/spark/subquery_in.q.out | 660 +-
.../spark/table_access_keys_stats.q.out | 36 +-
.../clientpositive/spark/tez_join_tests.q.out | 26 +-
.../spark/tez_joins_explain.q.out | 26 +-
.../clientpositive/spark/transform_ppr1.q.out | 8 +-
.../clientpositive/spark/transform_ppr2.q.out | 4 +-
.../spark/truncate_column_buckets.q.out | 8 +-
.../results/clientpositive/spark/union10.q.out | 8 +-
.../results/clientpositive/spark/union11.q.out | 6 +-
.../results/clientpositive/spark/union12.q.out | 8 +-
.../results/clientpositive/spark/union14.q.out | 4 +-
.../results/clientpositive/spark/union15.q.out | 6 +-
.../results/clientpositive/spark/union16.q.out | 2 +-
.../results/clientpositive/spark/union17.q.out | 8 +-
.../results/clientpositive/spark/union18.q.out | 8 +-
.../results/clientpositive/spark/union19.q.out | 8 +-
.../results/clientpositive/spark/union2.q.out | 4 +-
.../results/clientpositive/spark/union20.q.out | 4 +-
.../results/clientpositive/spark/union22.q.out | 6 +-
.../results/clientpositive/spark/union24.q.out | 56 +-
.../results/clientpositive/spark/union25.q.out | 4 +-
.../results/clientpositive/spark/union30.q.out | 46 +-
.../results/clientpositive/spark/union31.q.out | 18 +-
.../results/clientpositive/spark/union4.q.out | 6 +-
.../results/clientpositive/spark/union5.q.out | 4 +-
.../results/clientpositive/spark/union6.q.out | 4 +-
.../results/clientpositive/spark/union7.q.out | 4 +-
.../results/clientpositive/spark/union9.q.out | 6 +-
.../clientpositive/spark/union_ppr.q.out | 8 +-
.../clientpositive/spark/union_remove_1.q.out | 6 +-
.../clientpositive/spark/union_remove_10.q.out | 8 +-
.../clientpositive/spark/union_remove_13.q.out | 8 +-
.../clientpositive/spark/union_remove_15.q.out | 8 +-
.../clientpositive/spark/union_remove_16.q.out | 8 +-
.../clientpositive/spark/union_remove_18.q.out | 6 +-
.../clientpositive/spark/union_remove_19.q.out | 54 +-
.../clientpositive/spark/union_remove_2.q.out | 6 +-
.../clientpositive/spark/union_remove_20.q.out | 6 +-
.../clientpositive/spark/union_remove_22.q.out | 6 +-
.../clientpositive/spark/union_remove_23.q.out | 10 +-
.../clientpositive/spark/union_remove_24.q.out | 6 +-
.../clientpositive/spark/union_remove_25.q.out | 6 +-
.../clientpositive/spark/union_remove_4.q.out | 6 +-
.../clientpositive/spark/union_remove_5.q.out | 6 +-
.../clientpositive/spark/union_remove_6.q.out | 6 +-
.../spark/union_remove_6_subq.q.out | 16 +-
.../clientpositive/spark/union_remove_7.q.out | 8 +-
.../clientpositive/spark/union_remove_8.q.out | 8 +-
.../clientpositive/spark/union_remove_9.q.out | 8 +-
.../clientpositive/spark/union_view.q.out | 24 +-
.../spark/vector_between_in.q.out | 52 +-
.../spark/vector_cast_constant.q.out | 33 +-
.../spark/vector_count_distinct.q.out | 10 +-
.../spark/vector_decimal_aggregate.q.out | 46 +-
.../spark/vector_distinct_2.q.out | 6 +-
.../clientpositive/spark/vector_elt.q.out | 12 +-
.../clientpositive/spark/vector_groupby_3.q.out | 6 +-
.../spark/vector_inner_join.q.out | 2 +
.../spark/vector_left_outer_join.q.out | 16 +-
.../spark/vector_mapjoin_reduce.q.out | 26 +-
.../clientpositive/spark/vector_orderby_5.q.out | 6 +-
.../spark/vector_outer_join1.q.out | 44 +-
.../spark/vector_outer_join2.q.out | 20 +-
.../spark/vector_string_concat.q.out | 6 +-
.../spark/vector_tablesample_rows.q.out | 424 +
.../clientpositive/spark/vectorization_0.q.out | 365 +-
.../clientpositive/spark/vectorization_1.q.out | 173 +
.../clientpositive/spark/vectorization_10.q.out | 117 +
.../clientpositive/spark/vectorization_11.q.out | 99 +
.../clientpositive/spark/vectorization_12.q.out | 238 +
.../clientpositive/spark/vectorization_13.q.out | 142 +-
.../clientpositive/spark/vectorization_14.q.out | 105 +-
.../clientpositive/spark/vectorization_15.q.out | 174 +-
.../clientpositive/spark/vectorization_16.q.out | 83 +-
.../clientpositive/spark/vectorization_17.q.out | 53 +-
.../clientpositive/spark/vectorization_2.q.out | 177 +
.../clientpositive/spark/vectorization_3.q.out | 182 +
.../clientpositive/spark/vectorization_4.q.out | 176 +
.../clientpositive/spark/vectorization_5.q.out | 171 +
.../clientpositive/spark/vectorization_6.q.out | 111 +
.../clientpositive/spark/vectorization_7.q.out | 18 +-
.../clientpositive/spark/vectorization_8.q.out | 18 +-
.../clientpositive/spark/vectorization_9.q.out | 83 +-
.../spark/vectorization_div0.q.out | 36 +-
.../spark/vectorization_pushdown.q.out | 15 +-
.../spark/vectorization_short_regress.q.out | 490 +-
.../clientpositive/spark/vectorized_case.q.out | 44 +-
.../spark/vectorized_mapjoin.q.out | 47 +-
.../spark/vectorized_math_funcs.q.out | 8 +-
.../spark/vectorized_nested_mapjoin.q.out | 24 +-
.../clientpositive/spark/vectorized_ptf.q.out | 331 +-
.../spark/vectorized_shufflejoin.q.out | 43 +-
.../spark/vectorized_string_funcs.q.out | 8 +-
.../spark/vectorized_timestamp_funcs.q.out | 68 +-
.../clientpositive/spark/windowing.q.out | 2 +-
ql/src/test/results/clientpositive/stats1.q.out | 4 +-
.../clientpositive/stats_only_null.q.out | 6 +-
ql/src/test/results/clientpositive/subq2.q.out | 24 +-
.../clientpositive/subquery_exists.q.out | 10 +-
.../clientpositive/subquery_exists_having.q.out | 28 +-
.../clientpositive/subquery_in_having.q.out | 1439 +-
.../clientpositive/subquery_notexists.q.out | 32 +-
.../subquery_notexists_having.q.out | 32 +-
.../clientpositive/subquery_notin_having.q.out | 26 +-
.../subquery_unqualcolumnrefs.q.out | 86 +-
.../symlink_text_input_format.q.out | 4 +-
.../temp_table_display_colstats_tbllvl.q.out | 116 +-
.../clientpositive/tez/explainanalyze_1.q.out | 10 +-
.../clientpositive/tez/explainanalyze_2.q.out | 370 +-
.../clientpositive/tez/explainanalyze_3.q.out | 4 +-
.../clientpositive/tez/explainanalyze_4.q.out | 12 +-
.../clientpositive/tez/explainanalyze_5.q.out | 20 +-
.../clientpositive/tez/explainuser_3.q.out | 6 +-
.../tez/hybridgrace_hashjoin_1.q.out | 12 +-
.../tez/hybridgrace_hashjoin_2.q.out | 24 +-
.../tez/vectorization_limit.q.out | 82 +-
.../results/clientpositive/timestamptz.q.out | 48 +-
.../results/clientpositive/timestamptz_1.q.out | 26 +-
.../results/clientpositive/timestamptz_2.q.out | 34 +-
.../truncate_column_buckets.q.out | 8 +-
.../results/clientpositive/tunable_ndv.q.out | 60 +-
.../clientpositive/udf_stddev_samp.q.out | 66 +-
.../results/clientpositive/udf_var_samp.q.out | 66 +-
.../results/clientpositive/udtf_explode.q.out | 4 +-
.../test/results/clientpositive/union10.q.out | 8 +-
.../test/results/clientpositive/union11.q.out | 6 +-
.../test/results/clientpositive/union12.q.out | 8 +-
.../test/results/clientpositive/union14.q.out | 4 +-
.../test/results/clientpositive/union15.q.out | 6 +-
.../test/results/clientpositive/union16.q.out | 50 +-
.../test/results/clientpositive/union17.q.out | 8 +-
.../test/results/clientpositive/union18.q.out | 8 +-
.../test/results/clientpositive/union19.q.out | 8 +-
ql/src/test/results/clientpositive/union2.q.out | 4 +-
.../test/results/clientpositive/union20.q.out | 4 +-
.../test/results/clientpositive/union24.q.out | 56 +-
.../test/results/clientpositive/union25.q.out | 4 +-
.../test/results/clientpositive/union30.q.out | 52 +-
.../test/results/clientpositive/union31.q.out | 18 +-
.../test/results/clientpositive/union34.q.out | 4 +-
ql/src/test/results/clientpositive/union4.q.out | 6 +-
ql/src/test/results/clientpositive/union5.q.out | 4 +-
ql/src/test/results/clientpositive/union6.q.out | 4 +-
ql/src/test/results/clientpositive/union7.q.out | 4 +-
ql/src/test/results/clientpositive/union9.q.out | 6 +-
.../clientpositive/union_pos_alias.q.out | 10 +-
.../results/clientpositive/union_remove_1.q.out | 12 +-
.../clientpositive/union_remove_10.q.out | 6 +-
.../clientpositive/union_remove_13.q.out | 6 +-
.../clientpositive/union_remove_15.q.out | 12 +-
.../clientpositive/union_remove_16.q.out | 12 +-
.../clientpositive/union_remove_18.q.out | 12 +-
.../clientpositive/union_remove_19.q.out | 108 +-
.../results/clientpositive/union_remove_2.q.out | 6 +-
.../clientpositive/union_remove_20.q.out | 12 +-
.../clientpositive/union_remove_22.q.out | 12 +-
.../clientpositive/union_remove_23.q.out | 10 +-
.../clientpositive/union_remove_24.q.out | 12 +-
.../clientpositive/union_remove_25.q.out | 12 +-
.../results/clientpositive/union_remove_4.q.out | 12 +-
.../results/clientpositive/union_remove_5.q.out | 6 +-
.../results/clientpositive/union_remove_6.q.out | 12 +-
.../clientpositive/union_remove_6_subq.q.out | 30 +-
.../results/clientpositive/union_remove_7.q.out | 12 +-
.../results/clientpositive/union_remove_8.q.out | 6 +-
.../results/clientpositive/union_remove_9.q.out | 6 +-
.../results/clientpositive/union_view.q.out | 24 +-
.../clientpositive/unionall_unbalancedppd.q.out | 35 +-
.../clientpositive/vector_aggregate_9.q.out | 239 +-
.../vector_binary_join_groupby.q.out | 8 +
.../clientpositive/vector_cast_constant.q.out | 16 +-
.../results/clientpositive/vector_char_2.q.out | 8 +
.../clientpositive/vector_coalesce_2.q.out | 8 +
.../clientpositive/vector_complex_all.q.out | 6 +-
.../clientpositive/vector_complex_join.q.out | 28 +-
.../results/clientpositive/vector_count.q.out | 78 +-
.../results/clientpositive/vector_date_1.q.out | 2 +-
.../vector_decimal_aggregate.q.out | 20 +-
.../vector_decimal_precision.q.out | 16 +-
.../clientpositive/vector_decimal_round.q.out | 44 +-
.../clientpositive/vector_distinct_2.q.out | 4 +
.../clientpositive/vector_empty_where.q.out | 32 +
.../clientpositive/vector_groupby4.q.out | 4 +
.../clientpositive/vector_groupby6.q.out | 4 +
.../clientpositive/vector_groupby_3.q.out | 4 +
.../clientpositive/vector_groupby_mapjoin.q.out | 8 +
.../clientpositive/vector_groupby_reduce.q.out | 2522 +-
.../clientpositive/vector_grouping_sets.q.out | 8 +
.../clientpositive/vector_include_no_sel.q.out | 4 +
.../vector_interval_mapjoin.q.out | 6 +-
.../clientpositive/vector_mapjoin_reduce.q.out | 20 +-
.../vector_mr_diff_schema_alias.q.out | 26 +-
.../clientpositive/vector_null_projection.q.out | 8 +-
.../results/clientpositive/vector_nvl.q.out | 2 +-
.../clientpositive/vector_orderby_5.q.out | 4 +
.../clientpositive/vector_outer_join1.q.out | 4 +
.../clientpositive/vector_outer_join2.q.out | 4 +
.../clientpositive/vector_outer_join3.q.out | 6 +-
.../clientpositive/vector_outer_join4.q.out | 2 +-
.../vector_outer_reference_windowed.q.out | 1221 +
.../clientpositive/vector_ptf_part_simple.q.out | 2895 +
.../vector_reduce_groupby_decimal.q.out | 4 +
.../clientpositive/vector_string_concat.q.out | 4 +
.../vector_tablesample_rows.q.out | 100 +-
.../clientpositive/vector_when_case_null.q.out | 12 +-
.../clientpositive/vector_windowing.q.out | 9149 +
.../vector_windowing_expressions.q.out | 1822 +
.../clientpositive/vector_windowing_gby.q.out | 252 +
.../clientpositive/vector_windowing_gby2.q.out | 1015 +
.../vector_windowing_multipartitioning.q.out | 11288 +
.../vector_windowing_order_null.q.out | 989 +
.../vector_windowing_range_multiorder.q.out | 12239 +
.../clientpositive/vector_windowing_rank.q.out | 1543 +
.../vector_windowing_streaming.q.out | 836 +
.../vector_windowing_windowspec.q.out | 2060 +
.../vector_windowing_windowspec4.q.out | 211 +
.../clientpositive/vectorization_1.q.out | 146 +
.../clientpositive/vectorization_10.q.out | 114 +
.../clientpositive/vectorization_11.q.out | 96 +
.../clientpositive/vectorization_12.q.out | 1284 +-
.../clientpositive/vectorization_13.q.out | 43 +-
.../clientpositive/vectorization_14.q.out | 1301 +-
.../clientpositive/vectorization_15.q.out | 155 +-
.../clientpositive/vectorization_16.q.out | 364 +-
.../clientpositive/vectorization_17.q.out | 27 +-
.../clientpositive/vectorization_2.q.out | 150 +
.../clientpositive/vectorization_3.q.out | 155 +
.../clientpositive/vectorization_4.q.out | 149 +
.../clientpositive/vectorization_5.q.out | 144 +
.../clientpositive/vectorization_6.q.out | 108 +
.../clientpositive/vectorization_7.q.out | 10 +-
.../clientpositive/vectorization_8.q.out | 10 +-
.../clientpositive/vectorization_9.q.out | 364 +-
.../clientpositive/vectorization_limit.q.out | 28 +-
.../clientpositive/vectorization_pushdown.q.out | 2 +-
.../clientpositive/vectorized_case.q.out | 20 +-
.../clientpositive/vectorized_casts.q.out | 85 +-
.../clientpositive/vectorized_date_funcs.q.out | 4 +
.../vectorized_distinct_gby.q.out | 78 +-
.../clientpositive/vectorized_mapjoin.q.out | 16 +-
.../clientpositive/vectorized_mapjoin2.q.out | 12 +-
.../vectorized_parquet_types.q.out | 16 +-
.../clientpositive/vectorized_shufflejoin.q.out | 19 +-
.../clientpositive/vectorized_timestamp.q.out | 314 +-
.../vectorized_timestamp_funcs.q.out | 49 +-
.../test/results/clientpositive/view_cbo.q.out | 12 +-
.../results/clientpositive/windowing_gby2.q.out | 12 +-
.../clientpositive/windowing_navfn.q.out | 2 +-
.../clientpositive/windowing_streaming.q.out | 6 +-
serde/if/serde.thrift | 6 +-
.../src/gen/thrift/gen-cpp/serde_constants.cpp | 6 +-
serde/src/gen/thrift/gen-cpp/serde_constants.h | 2 +-
.../hadoop/hive/serde/serdeConstants.java | 6 +-
.../org/apache/hadoop/hive/serde/Types.php | 10 +-
.../org_apache_hadoop_hive_serde/constants.py | 6 +-
serde/src/gen/thrift/gen-rb/serde_constants.rb | 6 +-
.../apache/hadoop/hive/serde2/SerDeUtils.java | 6 +-
.../binarysortable/BinarySortableSerDe.java | 25 +-
.../serde2/io/TimestampLocalTZWritable.java | 449 +
.../hive/serde2/io/TimestampTZWritable.java | 427 -
.../hadoop/hive/serde2/lazy/LazyFactory.java | 6 +-
.../hive/serde2/lazy/LazySerDeParameters.java | 19 +-
.../hive/serde2/lazy/LazyTimestampLocalTZ.java | 102 +
.../hive/serde2/lazy/LazyTimestampTZ.java | 91 -
.../hadoop/hive/serde2/lazy/LazyUtils.java | 6 +-
.../lazy/fast/LazySimpleDeserializeRead.java | 14 +-
.../LazyPrimitiveObjectInspectorFactory.java | 8 +-
.../LazyTimestampLocalTZObjectInspector.java | 52 +
.../LazyTimestampTZObjectInspector.java | 43 -
.../serde2/lazybinary/LazyBinaryFactory.java | 6 +-
.../hive/serde2/lazybinary/LazyBinarySerDe.java | 8 +-
.../lazybinary/LazyBinaryTimestampLocalTZ.java | 43 +
.../lazybinary/LazyBinaryTimestampTZ.java | 36 -
.../hive/serde2/lazybinary/LazyBinaryUtils.java | 6 +-
.../ObjectInspectorConverters.java | 14 +-
.../objectinspector/ObjectInspectorUtils.java | 22 +-
.../PrimitiveObjectInspector.java | 6 +-
.../JavaTimestampLocalTZObjectInspector.java | 103 +
.../JavaTimestampTZObjectInspector.java | 76 -
.../PrimitiveObjectInspectorConverter.java | 23 +-
.../PrimitiveObjectInspectorFactory.java | 32 +-
.../PrimitiveObjectInspectorUtils.java | 123 +-
...SettableTimestampLocalTZObjectInspector.java | 34 +
.../SettableTimestampTZObjectInspector.java | 34 -
.../TimestampLocalTZObjectInspector.java | 29 +
.../primitive/TimestampTZObjectInspector.java | 29 -
...ConstantTimestampLocalTZObjectInspector.java | 40 +
...tableConstantTimestampTZObjectInspector.java | 36 -
...WritableTimestampLocalTZObjectInspector.java | 107 +
.../WritableTimestampTZObjectInspector.java | 79 -
.../serde2/thrift/ThriftJDBCBinarySerDe.java | 2 +-
.../apache/hadoop/hive/serde2/thrift/Type.java | 10 +-
.../typeinfo/TimestampLocalTZTypeInfo.java | 104 +
.../hive/serde2/typeinfo/TypeInfoFactory.java | 21 +-
.../hive/serde2/typeinfo/TypeInfoUtils.java | 28 +-
.../hive/serde2/io/TestTimestampTZWritable.java | 20 +-
.../hive/serde2/typeinfo/TestTypeInfoUtils.java | 34 +-
service-rpc/if/TCLIService.thrift | 8 +-
.../thrift/gen-cpp/TCLIService_constants.cpp | 2 +-
.../gen/thrift/gen-cpp/TCLIService_types.cpp | 4 +-
.../src/gen/thrift/gen-cpp/TCLIService_types.h | 2 +-
.../rpc/thrift/TCLIServiceConstants.java | 4 +-
.../apache/hive/service/rpc/thrift/TTypeId.java | 4 +-
service-rpc/src/gen/thrift/gen-php/Types.php | 6 +-
.../gen/thrift/gen-py/TCLIService/constants.py | 2 +-
.../src/gen/thrift/gen-py/TCLIService/ttypes.py | 6 +-
.../thrift/gen-rb/t_c_l_i_service_constants.rb | 2 +-
.../gen/thrift/gen-rb/t_c_l_i_service_types.rb | 6 +-
service/pom.xml | 11 +
.../org/apache/hive/tmpl/QueryProfileTmpl.jamon | 14 +-
.../apache/hive/service/cli/ColumnValue.java | 2 +-
.../apache/hive/service/cli/TypeDescriptor.java | 2 +-
.../operation/ExecuteStatementOperation.java | 8 +-
.../hive/service/cli/operation/Operation.java | 16 +-
.../service/cli/operation/SQLOperation.java | 5 +-
.../service/cli/session/HiveSessionHook.java | 4 +
.../service/cli/thrift/ThriftCLIService.java | 6 +-
.../cli/thrift/ThriftHttpCLIService.java | 19 +-
.../service/servlet/QueryProfileServlet.java | 4 +-
.../apache/hadoop/hive/shims/Hadoop23Shims.java | 60 +-
.../hadoop/hive/shims/TestHadoop23Shims.java | 14 +-
.../apache/hadoop/hive/shims/HadoopShims.java | 10 +-
.../hive/thrift/HadoopThriftAuthBridge.java | 16 +
.../apache/hive/spark/client/SparkClient.java | 9 +-
.../hive/spark/client/SparkClientFactory.java | 22 +-
.../hive/spark/client/SparkClientImpl.java | 68 +-
.../hive/spark/client/rpc/RpcConfiguration.java | 6 +-
.../hive/spark/client/rpc/RpcDispatcher.java | 7 +-
.../apache/hive/spark/client/rpc/RpcServer.java | 1 -
.../apache/hive/spark/client/rpc/TestRpc.java | 55 +-
standalone-metastore/pom.xml | 232 +
.../gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 74036 ++++++
.../gen/thrift/gen-cpp/ThriftHiveMetastore.h | 23462 ++
.../ThriftHiveMetastore_server.skeleton.cpp | 844 +
.../thrift/gen-cpp/hive_metastore_constants.cpp | 65 +
.../thrift/gen-cpp/hive_metastore_constants.h | 48 +
.../gen/thrift/gen-cpp/hive_metastore_types.cpp | 21819 ++
.../gen/thrift/gen-cpp/hive_metastore_types.h | 9034 +
.../hive/metastore/api/AbortTxnRequest.java | 387 +
.../hive/metastore/api/AbortTxnsRequest.java | 438 +
.../metastore/api/AddDynamicPartitions.java | 864 +
.../metastore/api/AddForeignKeyRequest.java | 443 +
.../api/AddNotNullConstraintRequest.java | 443 +
.../metastore/api/AddPartitionsRequest.java | 849 +
.../hive/metastore/api/AddPartitionsResult.java | 447 +
.../metastore/api/AddPrimaryKeyRequest.java | 443 +
.../api/AddUniqueConstraintRequest.java | 443 +
.../hadoop/hive/metastore/api/AggrStats.java | 542 +
.../metastore/api/AlreadyExistsException.java | 395 +
.../metastore/api/BinaryColumnStatsData.java | 696 +
.../metastore/api/BooleanColumnStatsData.java | 696 +
.../metastore/api/CacheFileMetadataRequest.java | 703 +
.../metastore/api/CacheFileMetadataResult.java | 387 +
.../hive/metastore/api/CheckLockRequest.java | 589 +
.../metastore/api/ClearFileMetadataRequest.java | 438 +
.../metastore/api/ClearFileMetadataResult.java | 283 +
.../hive/metastore/api/ClientCapabilities.java | 441 +
.../hive/metastore/api/ClientCapability.java | 45 +
.../hive/metastore/api/CmRecycleRequest.java | 488 +
.../hive/metastore/api/CmRecycleResponse.java | 283 +
.../hive/metastore/api/ColumnStatistics.java | 549 +
.../metastore/api/ColumnStatisticsData.java | 675 +
.../metastore/api/ColumnStatisticsDesc.java | 798 +
.../hive/metastore/api/ColumnStatisticsObj.java | 593 +
.../hive/metastore/api/CommitTxnRequest.java | 387 +
.../hive/metastore/api/CompactionRequest.java | 977 +
.../hive/metastore/api/CompactionResponse.java | 583 +
.../hive/metastore/api/CompactionType.java | 45 +
.../api/ConfigValSecurityException.java | 395 +
.../api/CurrentNotificationEventId.java | 387 +
.../hive/metastore/api/DataOperationType.java | 57 +
.../hadoop/hive/metastore/api/Database.java | 1095 +
.../apache/hadoop/hive/metastore/api/Date.java | 387 +
.../hive/metastore/api/DateColumnStatsData.java | 823 +
.../hadoop/hive/metastore/api/Decimal.java | 497 +
.../metastore/api/DecimalColumnStatsData.java | 823 +
.../metastore/api/DoubleColumnStatsData.java | 799 +
.../metastore/api/DropConstraintRequest.java | 591 +
.../hive/metastore/api/DropPartitionsExpr.java | 505 +
.../metastore/api/DropPartitionsRequest.java | 1112 +
.../metastore/api/DropPartitionsResult.java | 447 +
.../hive/metastore/api/EnvironmentContext.java | 447 +
.../hive/metastore/api/EventRequestType.java | 48 +
.../hadoop/hive/metastore/api/FieldSchema.java | 603 +
.../metastore/api/FileMetadataExprType.java | 42 +
.../hive/metastore/api/FireEventRequest.java | 861 +
.../metastore/api/FireEventRequestData.java | 309 +
.../hive/metastore/api/FireEventResponse.java | 283 +
.../hive/metastore/api/ForeignKeysRequest.java | 707 +
.../hive/metastore/api/ForeignKeysResponse.java | 443 +
.../hadoop/hive/metastore/api/Function.java | 1199 +
.../hadoop/hive/metastore/api/FunctionType.java | 42 +
.../metastore/api/GetAllFunctionsResponse.java | 447 +
.../api/GetFileMetadataByExprRequest.java | 773 +
.../api/GetFileMetadataByExprResult.java | 553 +
.../metastore/api/GetFileMetadataRequest.java | 438 +
.../metastore/api/GetFileMetadataResult.java | 540 +
.../metastore/api/GetOpenTxnsInfoResponse.java | 542 +
.../hive/metastore/api/GetOpenTxnsResponse.java | 750 +
.../api/GetPrincipalsInRoleRequest.java | 389 +
.../api/GetPrincipalsInRoleResponse.java | 443 +
.../api/GetRoleGrantsForPrincipalRequest.java | 502 +
.../api/GetRoleGrantsForPrincipalResponse.java | 443 +
.../hive/metastore/api/GetTableRequest.java | 605 +
.../hive/metastore/api/GetTableResult.java | 394 +
.../hive/metastore/api/GetTablesRequest.java | 659 +
.../hive/metastore/api/GetTablesResult.java | 443 +
.../api/GrantRevokePrivilegeRequest.java | 620 +
.../api/GrantRevokePrivilegeResponse.java | 390 +
.../metastore/api/GrantRevokeRoleRequest.java | 1059 +
.../metastore/api/GrantRevokeRoleResponse.java | 390 +
.../hive/metastore/api/GrantRevokeType.java | 45 +
.../hive/metastore/api/HeartbeatRequest.java | 489 +
.../metastore/api/HeartbeatTxnRangeRequest.java | 482 +
.../api/HeartbeatTxnRangeResponse.java | 588 +
.../hive/metastore/api/HiveObjectPrivilege.java | 729 +
.../hive/metastore/api/HiveObjectRef.java | 872 +
.../hive/metastore/api/HiveObjectType.java | 54 +
.../apache/hadoop/hive/metastore/api/Index.java | 1374 +
.../api/IndexAlreadyExistsException.java | 395 +
.../metastore/api/InsertEventRequestData.java | 700 +
.../metastore/api/InvalidInputException.java | 395 +
.../metastore/api/InvalidObjectException.java | 395 +
.../api/InvalidOperationException.java | 395 +
.../api/InvalidPartitionException.java | 395 +
.../hive/metastore/api/LockComponent.java | 1158 +
.../hadoop/hive/metastore/api/LockLevel.java | 48 +
.../hadoop/hive/metastore/api/LockRequest.java | 861 +
.../hadoop/hive/metastore/api/LockResponse.java | 500 +
.../hadoop/hive/metastore/api/LockState.java | 51 +
.../hadoop/hive/metastore/api/LockType.java | 48 +
.../hive/metastore/api/LongColumnStatsData.java | 799 +
.../hive/metastore/api/MetaException.java | 395 +
.../hive/metastore/api/MetadataPpdResult.java | 517 +
.../hive/metastore/api/NoSuchLockException.java | 395 +
.../metastore/api/NoSuchObjectException.java | 395 +
.../hive/metastore/api/NoSuchTxnException.java | 395 +
.../api/NotNullConstraintsRequest.java | 490 +
.../api/NotNullConstraintsResponse.java | 443 +
.../hive/metastore/api/NotificationEvent.java | 1006 +
.../metastore/api/NotificationEventRequest.java | 490 +
.../api/NotificationEventResponse.java | 443 +
.../api/NotificationEventsCountRequest.java | 488 +
.../api/NotificationEventsCountResponse.java | 387 +
.../hive/metastore/api/OpenTxnRequest.java | 702 +
.../hive/metastore/api/OpenTxnsResponse.java | 438 +
.../apache/hadoop/hive/metastore/api/Order.java | 497 +
.../hadoop/hive/metastore/api/Partition.java | 1229 +
.../hive/metastore/api/PartitionEventType.java | 42 +
.../api/PartitionListComposingSpec.java | 449 +
.../hive/metastore/api/PartitionSpec.java | 826 +
.../api/PartitionSpecWithSharedSD.java | 558 +
.../hive/metastore/api/PartitionWithoutSD.java | 1016 +
.../metastore/api/PartitionsByExprRequest.java | 815 +
.../metastore/api/PartitionsByExprResult.java | 542 +
.../metastore/api/PartitionsStatsRequest.java | 790 +
.../metastore/api/PartitionsStatsResult.java | 490 +
.../hive/metastore/api/PrimaryKeysRequest.java | 490 +
.../hive/metastore/api/PrimaryKeysResponse.java | 443 +
.../metastore/api/PrincipalPrivilegeSet.java | 906 +
.../hive/metastore/api/PrincipalType.java | 48 +
.../hadoop/hive/metastore/api/PrivilegeBag.java | 449 +
.../hive/metastore/api/PrivilegeGrantInfo.java | 815 +
.../metastore/api/PutFileMetadataRequest.java | 710 +
.../metastore/api/PutFileMetadataResult.java | 283 +
.../hive/metastore/api/RequestPartsSpec.java | 438 +
.../hadoop/hive/metastore/api/ResourceType.java | 48 +
.../hadoop/hive/metastore/api/ResourceUri.java | 511 +
.../apache/hadoop/hive/metastore/api/Role.java | 601 +
.../hive/metastore/api/RolePrincipalGrant.java | 1035 +
.../hive/metastore/api/SQLForeignKey.java | 1715 +
.../metastore/api/SQLNotNullConstraint.java | 1005 +
.../hive/metastore/api/SQLPrimaryKey.java | 1103 +
.../hive/metastore/api/SQLUniqueConstraint.java | 1103 +
.../hadoop/hive/metastore/api/Schema.java | 605 +
.../hadoop/hive/metastore/api/SerDeInfo.java | 655 +
.../api/SetPartitionsStatsRequest.java | 550 +
.../hive/metastore/api/ShowCompactRequest.java | 283 +
.../hive/metastore/api/ShowCompactResponse.java | 443 +
.../api/ShowCompactResponseElement.java | 1641 +
.../hive/metastore/api/ShowLocksRequest.java | 710 +
.../hive/metastore/api/ShowLocksResponse.java | 449 +
.../metastore/api/ShowLocksResponseElement.java | 1929 +
.../hadoop/hive/metastore/api/SkewedInfo.java | 834 +
.../hive/metastore/api/StorageDescriptor.java | 1748 +
.../metastore/api/StringColumnStatsData.java | 791 +
.../apache/hadoop/hive/metastore/api/Table.java | 1948 +
.../hadoop/hive/metastore/api/TableMeta.java | 701 +
.../hive/metastore/api/TableStatsRequest.java | 640 +
.../hive/metastore/api/TableStatsResult.java | 443 +
.../hive/metastore/api/ThriftHiveMetastore.java | 188205 ++++++++++++++++
.../hive/metastore/api/TxnAbortedException.java | 395 +
.../hadoop/hive/metastore/api/TxnInfo.java | 1220 +
.../hive/metastore/api/TxnOpenException.java | 395 +
.../hadoop/hive/metastore/api/TxnState.java | 48 +
.../apache/hadoop/hive/metastore/api/Type.java | 768 +
.../metastore/api/UniqueConstraintsRequest.java | 490 +
.../api/UniqueConstraintsResponse.java | 443 +
.../hive/metastore/api/UnknownDBException.java | 395 +
.../api/UnknownPartitionException.java | 395 +
.../metastore/api/UnknownTableException.java | 395 +
.../hive/metastore/api/UnlockRequest.java | 387 +
.../hadoop/hive/metastore/api/Version.java | 499 +
.../metastore/api/hive_metastoreConstants.java | 87 +
.../gen-php/metastore/ThriftHiveMetastore.php | 47128 ++++
.../src/gen/thrift/gen-php/metastore/Types.php | 21262 ++
.../hive_metastore/ThriftHiveMetastore-remote | 1305 +
.../hive_metastore/ThriftHiveMetastore.py | 38297 ++++
.../thrift/gen-py/hive_metastore/__init__.py | 1 +
.../thrift/gen-py/hive_metastore/constants.py | 35 +
.../gen/thrift/gen-py/hive_metastore/ttypes.py | 15163 ++
.../thrift/gen-rb/hive_metastore_constants.rb | 57 +
.../gen/thrift/gen-rb/hive_metastore_types.rb | 3516 +
.../gen/thrift/gen-rb/thrift_hive_metastore.rb | 10672 +
.../hadoop/hive/metastore/ThreadPool.java | 63 +
.../hive/metastore/conf/MetastoreConf.java | 1514 +
.../hive/metastore/metrics/JsonReporter.java | 166 +
.../hive/metastore/metrics/JvmPauseMonitor.java | 222 +
.../hadoop/hive/metastore/metrics/Metrics.java | 243 +
.../metastore/metrics/MetricsConstants.java | 46 +
.../hive/metastore/metrics/PerfLogger.java | 194 +
.../hive/metastore/model/MColumnDescriptor.java | 51 +
.../hive/metastore/model/MConstraint.java | 188 +
.../hive/metastore/model/MDBPrivilege.java | 132 +
.../hadoop/hive/metastore/model/MDatabase.java | 128 +
.../hive/metastore/model/MDelegationToken.java | 45 +
.../hive/metastore/model/MFieldSchema.java | 80 +
.../hadoop/hive/metastore/model/MFunction.java | 119 +
.../hive/metastore/model/MGlobalPrivilege.java | 120 +
.../hadoop/hive/metastore/model/MIndex.java | 200 +
.../hadoop/hive/metastore/model/MMasterKey.java | 55 +
.../metastore/model/MMetastoreDBProperties.java | 56 +
.../hive/metastore/model/MNotificationLog.java | 98 +
.../metastore/model/MNotificationNextId.java | 42 +
.../hadoop/hive/metastore/model/MOrder.java | 62 +
.../hadoop/hive/metastore/model/MPartition.java | 155 +
.../model/MPartitionColumnPrivilege.java | 161 +
.../model/MPartitionColumnStatistics.java | 272 +
.../hive/metastore/model/MPartitionEvent.java | 90 +
.../metastore/model/MPartitionPrivilege.java | 139 +
.../hive/metastore/model/MPrincipalDesc.java | 59 +
.../hive/metastore/model/MResourceUri.java | 49 +
.../hadoop/hive/metastore/model/MRole.java | 80 +
.../hadoop/hive/metastore/model/MRoleMap.java | 120 +
.../hadoop/hive/metastore/model/MSerDeInfo.java | 81 +
.../metastore/model/MStorageDescriptor.java | 277 +
.../hive/metastore/model/MStringList.java | 62 +
.../hadoop/hive/metastore/model/MTable.java | 256 +
.../metastore/model/MTableColumnPrivilege.java | 160 +
.../metastore/model/MTableColumnStatistics.java | 263 +
.../hive/metastore/model/MTablePrivilege.java | 139 +
.../hadoop/hive/metastore/model/MType.java | 105 +
.../hive/metastore/model/MVersionTable.java | 57 +
.../security/DelegationTokenIdentifier.java | 52 +
.../security/DelegationTokenSecretManager.java | 125 +
.../security/DelegationTokenStore.java | 118 +
.../security/HadoopThriftAuthBridge.java | 684 +
.../security/HadoopThriftAuthBridge23.java | 114 +
.../metastore/security/MemoryTokenStore.java | 136 +
.../MetastoreDelegationTokenManager.java | 172 +
.../metastore/security/TFilterTransport.java | 99 +
.../security/TUGIAssumingTransport.java | 73 +
.../security/TUGIContainingTransport.java | 96 +
.../TokenStoreDelegationTokenSecretManager.java | 333 +
.../hadoop/hive/metastore/utils/HdfsUtils.java | 125 +
.../hive/metastore/utils/SecurityUtils.java | 40 +
.../hive/metastore/utils/StringUtils.java | 112 +
.../MetastoreDelegationTokenSupport.java | 68 +
.../src/main/resources/package.jdo | 1087 +
.../src/main/resources/thrift-replacements.txt | 69 +
.../src/main/thrift/hive_metastore.thrift | 1613 +
.../hive/metastore/conf/TestMetastoreConf.java | 414 +
.../hive/metastore/metrics/TestMetrics.java | 200 +
.../hive/metastore/utils/TestHdfsUtils.java | 193 +
.../apache/hadoop/hive/common/io/Allocator.java | 17 +
.../apache/hadoop/hive/common/io/DataCache.java | 6 +
.../hadoop/hive/common/io/DiskRangeList.java | 80 +-
.../hive/common/io/FileMetadataCache.java | 51 +
.../io/encoded/MemoryBufferOrBuffers.java | 24 +
.../hive/common/type/FastHiveDecimal.java | 18 +
.../hive/common/type/FastHiveDecimalImpl.java | 71 +-
.../hive/ql/io/sarg/SearchArgumentImpl.java | 5 +-
.../hive/serde2/io/HiveDecimalWritable.java | 58 +
.../apache/hive/common/util/BloomFilter.java | 37 +-
.../apache/hive/common/util/BloomKFilter.java | 472 +
.../hive/common/io/TestDiskRangeList.java | 106 +
.../hive/common/type/HiveDecimalTestBase.java | 10 +
.../hive/common/type/TestHiveDecimal.java | 73 +
.../hive/common/util/TestBloomFilter.java | 136 +-
.../hive/common/util/TestBloomKFilter.java | 699 +
.../ptest2/conf/deployed/master-mr2.properties | 57 +-
.../ptest2/conf/server-env.properties.example | 23 +
.../ptest/api/server/ExecutionController.java | 5 +-
.../hive/ptest/api/server/TestExecutor.java | 16 +-
.../org/apache/hive/ptest/execution/PTest.java | 18 +-
.../hive/ptest/execution/conf/Context.java | 84 +
.../conf/ExecutionContextConfiguration.java | 20 +-
.../ptest/execution/conf/TestConfiguration.java | 20 +-
.../hive/ptest/execution/conf/TestParser.java | 3 +-
.../hive/ptest/execution/TestJIRAService.java | 6 +-
.../hive/ptest/execution/conf/TestContext.java | 68 +
.../execution/conf/TestTestConfiguration.java | 10 +-
.../apache/hadoop/hive/tools/GenVectorCode.java | 345 +-
2788 files changed, 803465 insertions(+), 684284 deletions(-)
----------------------------------------------------------------------