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/187eb760 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/187eb760 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/187eb760 Branch: refs/heads/hive-14535 Commit: 187eb760dbd7c8c345bc3613b27cadafd3cdd102 Parents: ccea0d6 Author: Wei Zheng <[email protected]> Authored: Fri May 5 10:17:31 2017 -0700 Committer: Wei Zheng <[email protected]> Committed: Fri May 5 10:17:31 2017 -0700 ---------------------------------------------------------------------- .gitignore | 2 + .travis.yml | 4 +- RELEASE_NOTES.txt | 649 +- accumulo-handler/pom.xml | 22 +- .../accumulo/AccumuloDefaultIndexScanner.java | 222 + .../hive/accumulo/AccumuloIndexLexicoder.java | 109 + .../hive/accumulo/AccumuloIndexScanner.java | 56 + .../accumulo/AccumuloIndexScannerException.java | 39 + .../hive/accumulo/AccumuloStorageHandler.java | 155 +- .../accumulo/mr/AccumuloIndexDefinition.java | 79 + .../mr/AccumuloIndexedOutputFormat.java | 334 + .../mr/HiveAccumuloTableOutputFormat.java | 62 +- .../accumulo/mr/IndexOutputConfigurator.java | 75 + .../hadoop/hive/accumulo/mr/package-info.java | 4 + .../predicate/AccumuloPredicateHandler.java | 87 +- .../predicate/AccumuloRangeGenerator.java | 123 +- .../predicate/PrimitiveComparisonFilter.java | 13 +- .../accumulo/serde/AccumuloIndexParameters.java | 100 + .../accumulo/serde/AccumuloSerDeParameters.java | 19 + .../hive/accumulo/serde/package-info.java | 4 + .../TestAccumuloDefaultIndexScanner.java | 218 + .../accumulo/TestAccumuloIndexLexicoder.java | 177 + .../accumulo/TestAccumuloIndexParameters.java | 112 + .../accumulo/TestAccumuloStorageHandler.java | 3 + .../predicate/TestAccumuloPredicateHandler.java | 11 +- .../predicate/TestAccumuloRangeGenerator.java | 201 +- .../src/test/queries/positive/accumulo_index.q | 44 + .../test/results/positive/accumulo_index.q.out | 180 + beeline/pom.xml | 2 +- .../java/org/apache/hive/beeline/BeeLine.java | 72 + .../org/apache/hive/beeline/BeeLineOpts.java | 15 +- .../java/org/apache/hive/beeline/Commands.java | 103 +- .../apache/hive/beeline/HiveSchemaHelper.java | 12 +- .../org/apache/hive/beeline/HiveSchemaTool.java | 71 +- .../UserHS2ConnectionFileParser.java | 2 +- .../logs/BeelineInPlaceUpdateStream.java | 17 + beeline/src/main/resources/BeeLine.properties | 1 + .../hive/beeline/TestBeelineArgParsing.java | 12 + .../apache/hive/beeline/TestHiveSchemaTool.java | 17 + cli/pom.xml | 2 +- .../org/apache/hadoop/hive/cli/RCFileCat.java | 13 +- .../apache/hadoop/hive/cli/TestRCFileCat.java | 4 +- common/pom.xml | 46 +- .../hive/common/CopyOnFirstWriteProperties.java | 344 + .../apache/hadoop/hive/common/FileUtils.java | 146 +- .../apache/hadoop/hive/common/JvmMetrics.java | 187 + .../hadoop/hive/common/JvmMetricsInfo.java | 65 + .../org/apache/hadoop/hive/common/LogUtils.java | 35 +- .../hadoop/hive/common/MemoryEstimate.java | 29 + .../hadoop/hive/common/StatsSetupConst.java | 2 +- .../hadoop/hive/common/StringInternUtils.java | 16 +- .../hive/common/ValidCompactorTxnList.java | 11 +- .../hadoop/hive/common/ValidReadTxnList.java | 115 +- .../apache/hadoop/hive/common/ValidTxnList.java | 18 +- .../hive/common/jsonexplain/Connection.java | 35 + .../hive/common/jsonexplain/DagJsonParser.java | 167 + .../common/jsonexplain/DagJsonParserUtils.java | 53 + .../common/jsonexplain/JsonParserFactory.java | 4 + .../hadoop/hive/common/jsonexplain/Op.java | 358 + .../hadoop/hive/common/jsonexplain/Printer.java | 41 + .../hadoop/hive/common/jsonexplain/Stage.java | 262 + .../hadoop/hive/common/jsonexplain/Vertex.java | 323 + .../jsonexplain/spark/SparkJsonParser.java | 35 + .../hive/common/jsonexplain/tez/Connection.java | 30 - .../hadoop/hive/common/jsonexplain/tez/Op.java | 356 - .../hive/common/jsonexplain/tez/Printer.java | 41 - .../hive/common/jsonexplain/tez/Stage.java | 262 - .../common/jsonexplain/tez/TezJsonParser.java | 153 +- .../jsonexplain/tez/TezJsonParserUtils.java | 53 - .../hive/common/jsonexplain/tez/Vertex.java | 331 - .../hadoop/hive/common/log/InPlaceUpdate.java | 17 + .../hadoop/hive/common/log/ProgressMonitor.java | 17 + .../metrics/metrics2/CodahaleMetrics.java | 192 +- .../metrics/metrics2/CodahaleReporter.java | 29 + .../metrics2/ConsoleMetricsReporter.java | 55 + .../metrics/metrics2/JmxMetricsReporter.java | 56 + .../metrics2/JsonFileMetricsReporter.java | 136 + .../metrics/metrics2/Metrics2Reporter.java | 62 + .../org/apache/hadoop/hive/conf/HiveConf.java | 131 +- .../apache/hadoop/hive/conf/HiveConfUtil.java | 13 +- .../apache/hadoop/hive/ql/log/PerfLogger.java | 1 + .../java/org/apache/hive/http/ConfServlet.java | 10 +- .../java/org/apache/hive/http/HttpServer.java | 69 +- .../hadoop/hive/common/TestFileUtils.java | 1 - .../hive/common/TestValidReadTxnList.java | 29 +- .../metrics/metrics2/TestCodahaleMetrics.java | 7 +- .../metrics2/TestCodahaleReportersConf.java | 145 + contrib/pom.xml | 2 +- .../clientnegative/case_with_row_sequence.q.out | 16 +- data/files/e011_01.txt | 4 + data/files/events.txt | 200 + .../metastore_export/csv/TABLE_PARAMS.txt | 143 - .../metastore_export/csv/TAB_COL_STATS.txt | 425 - data/files/vector_ptf_part_simple.txt | 40 + docs/changes/ChangesFancyStyle.css | 170 - docs/changes/ChangesSimpleStyle.css | 49 - docs/changes/changes2html.pl | 282 - docs/site.css | 305 - docs/stylesheets/project.xml | 41 - docs/stylesheets/site.vsl | 317 - docs/velocity.properties | 17 - docs/xdocs/index.xml | 38 - docs/xdocs/language_manual/cli.xml | 208 - .../data-manipulation-statements.xml | 234 - docs/xdocs/language_manual/joins.xml | 212 - docs/xdocs/language_manual/var_substitution.xml | 130 - .../working_with_bucketed_tables.xml | 87 - docs/xdocs/udf/reflect.xml | 51 - druid-handler/pom.xml | 18 +- .../hadoop/hive/druid/DruidStorageHandler.java | 27 +- .../hive/druid/DruidStorageHandlerUtils.java | 72 +- .../hadoop/hive/druid/io/DruidOutputFormat.java | 13 +- .../druid/io/DruidQueryBasedInputFormat.java | 12 +- .../serde/DruidGroupByQueryRecordReader.java | 8 +- .../hive/druid/TestDruidStorageHandler.java | 78 +- .../hive/ql/io/TestDruidRecordWriter.java | 8 +- errata.txt | 4 + hbase-handler/pom.xml | 2 +- .../src/test/queries/negative/hbase_ddl.q | 9 + .../src/test/queries/positive/hbase_ddl.q | 20 + .../src/test/queries/positive/hbase_queries.q | 1 + .../src/test/results/negative/hbase_ddl.q.out | 29 + .../src/test/results/positive/hbase_ddl.q.out | 186 + hcatalog/build.properties | 2 +- hcatalog/core/pom.xml | 12 +- .../apache/hive/hcatalog/cli/TestPermsGrp.java | 6 +- hcatalog/hcatalog-pig-adapter/pom.xml | 2 +- hcatalog/pom.xml | 24 +- hcatalog/server-extensions/pom.xml | 2 +- .../listener/DbNotificationListener.java | 85 +- .../MetaStoreEventListenerConstants.java | 33 + hcatalog/streaming/pom.xml | 2 +- .../hcatalog/streaming/StrictRegexWriter.java | 188 + .../hive/hcatalog/streaming/TestStreaming.java | 115 +- hcatalog/webhcat/java-client/pom.xml | 2 +- .../hive/hcatalog/api/TestHCatClient.java | 2 +- hcatalog/webhcat/svr/pom.xml | 76 +- .../hive/hcatalog/templeton/AppConfig.java | 37 + .../hcatalog/templeton/DeleteDelegator.java | 6 +- .../hive/hcatalog/templeton/HiveDelegator.java | 2 +- .../hive/hcatalog/templeton/JarDelegator.java | 2 +- .../hive/hcatalog/templeton/JobCallable.java | 115 + .../hcatalog/templeton/JobRequestExecutor.java | 341 + .../hcatalog/templeton/LauncherDelegator.java | 231 +- .../hive/hcatalog/templeton/ListDelegator.java | 148 +- .../apache/hive/hcatalog/templeton/Main.java | 37 +- .../hive/hcatalog/templeton/PigDelegator.java | 2 +- .../hcatalog/templeton/SecureProxySupport.java | 3 + .../apache/hive/hcatalog/templeton/Server.java | 82 +- .../hive/hcatalog/templeton/SqoopDelegator.java | 2 +- .../hcatalog/templeton/StatusDelegator.java | 69 +- .../hcatalog/templeton/StreamingDelegator.java | 2 +- .../templeton/TooManyRequestsException.java | 35 + .../templeton/tool/TempletonControllerJob.java | 11 +- .../hcatalog/templeton/tool/TempletonUtils.java | 1 + .../ConcurrentJobRequestsTestBase.java | 231 + .../templeton/MockAnswerTestHelper.java | 56 + .../templeton/TestConcurrentJobRequests.java | 79 + .../TestConcurrentJobRequestsThreads.java | 134 + ...tConcurrentJobRequestsThreadsAndTimeout.java | 374 + hplsql/pom.xml | 2 +- .../main/java/org/apache/hive/hplsql/Udf.java | 26 +- .../org/apache/hive/hplsql/TestHplsqlUdf.java | 59 + itests/custom-serde/pom.xml | 2 +- itests/custom-udfs/pom.xml | 2 +- itests/custom-udfs/udf-classloader-udf1/pom.xml | 2 +- itests/custom-udfs/udf-classloader-udf2/pom.xml | 2 +- itests/custom-udfs/udf-classloader-util/pom.xml | 2 +- .../udf-vectorized-badexample/pom.xml | 2 +- itests/hcatalog-unit/pom.xml | 2 +- .../listener/DummyRawStoreFailEvent.java | 7 + .../listener/TestDbNotificationListener.java | 190 + itests/hive-blobstore/pom.xml | 2 +- ...import_addpartition_blobstore_to_blobstore.q | 45 + .../import_addpartition_blobstore_to_local.q | 44 + ...import_addpartition_blobstore_to_warehouse.q | 41 + .../import_addpartition_local_to_blobstore.q | 44 + .../import_blobstore_to_blobstore.q | 30 + .../import_blobstore_to_blobstore_nonpart.q | 25 + .../clientpositive/import_blobstore_to_local.q | 30 + .../import_blobstore_to_warehouse.q | 28 + .../import_blobstore_to_warehouse_nonpart.q | 23 + .../clientpositive/import_local_to_blobstore.q | 31 + .../insert_blobstore_to_blobstore.q | 29 + .../insert_empty_into_blobstore.q | 53 + .../test/queries/clientpositive/orc_buckets.q | 31 + .../queries/clientpositive/orc_format_nonpart.q | 30 + .../queries/clientpositive/orc_format_part.q | 67 + .../clientpositive/orc_nonstd_partitions_loc.q | 100 + .../queries/clientpositive/rcfile_buckets.q | 31 + .../clientpositive/rcfile_format_nonpart.q | 30 + .../queries/clientpositive/rcfile_format_part.q | 67 + .../rcfile_nonstd_partitions_loc.q | 100 + .../clientpositive/zero_rows_blobstore.q | 19 + .../queries/clientpositive/zero_rows_hdfs.q | 18 + .../src/test/resources/hive-site.xml | 5 + ...rt_addpartition_blobstore_to_blobstore.q.out | 283 + ...import_addpartition_blobstore_to_local.q.out | 283 + ...rt_addpartition_blobstore_to_warehouse.q.out | 271 + ...import_addpartition_local_to_blobstore.q.out | 277 + .../import_blobstore_to_blobstore.q.out | 161 + .../import_blobstore_to_blobstore_nonpart.q.out | 103 + .../import_blobstore_to_local.q.out | 161 + .../import_blobstore_to_warehouse.q.out | 157 + .../import_blobstore_to_warehouse_nonpart.q.out | 99 + .../import_local_to_blobstore.q.out | 159 + .../insert_blobstore_to_blobstore.q.out | 110 + .../insert_empty_into_blobstore.q.out | 155 + .../clientpositive/insert_into_table.q.out | 27 + .../results/clientpositive/orc_buckets.q.out | 183 + .../clientpositive/orc_format_nonpart.q.out | 195 + .../clientpositive/orc_format_part.q.out | 274 + .../orc_nonstd_partitions_loc.q.out | 513 + .../results/clientpositive/rcfile_buckets.q.out | 183 + .../clientpositive/rcfile_format_nonpart.q.out | 195 + .../clientpositive/rcfile_format_part.q.out | 274 + .../rcfile_nonstd_partitions_loc.q.out | 533 + .../write_final_output_blobstore.q.out | 20 + .../clientpositive/zero_rows_blobstore.q.out | 91 + .../results/clientpositive/zero_rows_hdfs.q.out | 89 + itests/hive-jmh/pom.xml | 2 +- itests/hive-minikdc/pom.xml | 2 +- .../apache/hive/minikdc/TestSSLWithMiniKdc.java | 101 + itests/hive-unit-hadoop2/pom.xml | 2 +- .../hive/ql/security/TestExtendedAcls.java | 166 - ...edMetastoreAuthorizationProviderWithACL.java | 1 - itests/hive-unit/pom.xml | 2 +- .../java/org/hadoop/hive/jdbc/SSLTestUtils.java | 103 + .../metastore/TestEmbeddedHiveMetaStore.java | 2 - .../hive/metastore/TestHiveMetaStore.java | 45 +- .../hive/metastore/TestHiveMetaStoreTxns.java | 8 +- .../hive/metastore/TestMetastoreVersion.java | 4 +- .../hive/metastore/TestReplChangeManager.java | 12 +- .../hadoop/hive/ql/TestAutoPurgeTables.java | 436 + ...estDDLWithRemoteMetastoreSecondNamenode.java | 31 + .../hadoop/hive/ql/TestLocationQueries.java | 8 +- .../ql/TestMetaStoreLimitPartitionRequest.java | 319 + .../hive/ql/TestReplicationScenarios.java | 824 +- .../hive/ql/security/FolderPermissionBase.java | 792 - .../hive/ql/security/TestFolderPermissions.java | 52 - ...StorageBasedMetastoreAuthorizationDrops.java | 205 - ...StorageBasedMetastoreAuthorizationReads.java | 127 - .../hive/ql/txn/compactor/TestCompactor.java | 90 +- .../hive/beeline/TestBeeLineWithArgs.java | 13 + .../org/apache/hive/beeline/TestSchemaTool.java | 9 +- .../org/apache/hive/jdbc/TestJdbcDriver2.java | 48 +- .../apache/hive/jdbc/TestJdbcWithMiniHS2.java | 44 + .../test/java/org/apache/hive/jdbc/TestSSL.java | 150 +- .../operation/TestOperationLoggingLayout.java | 16 - itests/pom.xml | 2 +- itests/qtest-accumulo/pom.xml | 2 +- itests/qtest-spark/pom.xml | 2 +- itests/qtest/pom.xml | 2 +- .../hadoop/hive/cli/TestBeeLineDriver.java | 4 +- .../test/resources/testconfiguration.properties | 44 +- itests/test-serde/pom.xml | 2 +- itests/util/pom.xml | 2 +- .../control/AbstractCoreBlobstoreCliDriver.java | 11 +- .../hadoop/hive/cli/control/CliConfigs.java | 1 + .../hive/cli/control/CoreAccumuloCliDriver.java | 10 +- .../hive/cli/control/CoreBeeLineDriver.java | 55 +- .../hadoop/hive/cli/control/CoreCliDriver.java | 12 +- .../hive/cli/control/CoreCompareCliDriver.java | 12 +- .../hive/cli/control/CoreHBaseCliDriver.java | 9 +- .../cli/control/CoreHBaseNegativeCliDriver.java | 9 +- .../hive/cli/control/CoreNegativeCliDriver.java | 12 +- .../hive/cli/control/CorePerfCliDriver.java | 12 +- .../hadoop/hive/ql/QTestProcessExecResult.java | 6 +- .../org/apache/hadoop/hive/ql/QTestUtil.java | 260 +- .../hadoop/hive/ql/parse/CoreParseNegative.java | 19 +- .../org/apache/hive/beeline/Parallelized.java | 64 + .../java/org/apache/hive/beeline/QFile.java | 333 + .../apache/hive/beeline/QFileBeeLineClient.java | 156 + .../org/apache/hive/beeline/package-info.java | 22 + .../org/apache/hive/beeline/qfile/QFile.java | 273 - .../hive/beeline/qfile/QFileBeeLineClient.java | 149 - .../apache/hive/beeline/qfile/package-info.java | 22 - jdbc-handler/pom.xml | 2 +- jdbc/pom.xml | 28 +- .../org/apache/hive/jdbc/HiveConnection.java | 24 +- .../org/apache/hive/jdbc/HiveStatement.java | 6 +- .../hive/jdbc/logs/InPlaceUpdateStream.java | 17 + llap-client/pom.xml | 2 +- .../apache/hadoop/hive/llap/io/api/LlapIo.java | 1 + .../llap/registry/impl/LlapRegistryService.java | 5 +- llap-common/pom.xml | 2 +- .../apache/hadoop/hive/llap/LlapDaemonInfo.java | 92 + llap-ext-client/pom.xml | 2 +- llap-server/bin/runLlapDaemon.sh | 4 +- llap-server/pom.xml | 10 +- .../llap/IncrementalObjectSizeEstimator.java | 4 +- .../hadoop/hive/llap/cache/BuddyAllocator.java | 181 +- .../hive/llap/cache/EvictionDispatcher.java | 25 +- .../hive/llap/cache/LlapOomDebugDump.java | 1 + .../hadoop/hive/llap/cache/LowLevelCache.java | 2 +- .../hive/llap/cache/LowLevelCacheImpl.java | 39 + .../llap/cache/LowLevelCacheMemoryManager.java | 39 +- .../hive/llap/cache/LowLevelCachePolicy.java | 2 +- .../llap/cache/LowLevelFifoCachePolicy.java | 26 +- .../llap/cache/LowLevelLrfuCachePolicy.java | 41 +- .../hadoop/hive/llap/cache/MemoryManager.java | 4 +- .../hive/llap/cache/SerDeLowLevelCacheImpl.java | 78 +- .../hadoop/hive/llap/cache/SimpleAllocator.java | 5 +- .../hive/llap/cache/SimpleBufferManager.java | 10 + .../hadoop/hive/llap/cli/LlapServiceDriver.java | 6 +- .../hadoop/hive/llap/cli/LlapSliderUtils.java | 58 + .../llap/cli/LlapStatusOptionsProcessor.java | 1 + .../hive/llap/cli/LlapStatusServiceDriver.java | 751 +- .../hive/llap/cli/status/LlapStatusHelpers.java | 449 + .../configuration/LlapDaemonConfiguration.java | 2 +- .../llap/daemon/impl/ContainerRunnerImpl.java | 4 + .../impl/EvictingPriorityBlockingQueue.java | 5 + .../hive/llap/daemon/impl/LlapDaemon.java | 88 +- .../hive/llap/daemon/impl/LlapDaemonMXBean.java | 6 + .../hadoop/hive/llap/daemon/impl/Scheduler.java | 2 + .../llap/daemon/impl/TaskExecutorService.java | 21 +- .../llap/daemon/impl/TaskRunnerCallable.java | 1 + .../services/impl/LlapIoMemoryServlet.java | 88 + .../daemon/services/impl/LlapWebServices.java | 1 + .../hive/llap/io/api/impl/LlapIoImpl.java | 60 +- .../llap/io/decode/OrcColumnVectorProducer.java | 6 +- .../llap/io/encoded/OrcEncodedDataReader.java | 39 +- .../llap/io/encoded/SerDeEncodedDataReader.java | 22 +- .../hive/llap/io/metadata/OrcMetadataCache.java | 24 +- .../llap/metrics/LlapDaemonExecutorMetrics.java | 2 +- .../llap/shufflehandler/ShuffleHandler.java | 37 +- .../resources/hive-webapps/llap/js/metrics.js | 6 +- .../main/resources/llap-cli-log4j2.properties | 25 +- .../resources/llap-daemon-log4j2.properties | 6 +- .../hive/llap/cache/TestBuddyAllocator.java | 12 +- .../hive/llap/cache/TestLowLevelCacheImpl.java | 8 +- .../llap/cache/TestLowLevelLrfuCachePolicy.java | 19 +- .../hive/llap/cache/TestOrcMetadataCache.java | 16 +- .../hive/llap/daemon/MiniLlapCluster.java | 5 + llap-tez/pom.xml | 2 +- .../metrics/LlapTaskSchedulerMetrics.java | 2 +- metastore/if/hive_metastore.thrift | 10 +- metastore/pom.xml | 24 +- .../upgrade/derby/022-HIVE-11107.derby.sql | 4 +- .../upgrade/derby/039-HIVE-12274.derby.sql | 32 + .../upgrade/derby/040-HIVE-16399.derby.sql | 1 + .../upgrade/derby/hive-schema-2.2.0.derby.sql | 20 +- .../upgrade/derby/hive-schema-2.3.0.derby.sql | 340 + .../upgrade/derby/hive-schema-3.0.0.derby.sql | 340 + .../derby/hive-txn-schema-2.2.0.derby.sql | 2 +- .../derby/hive-txn-schema-2.3.0.derby.sql | 134 + .../derby/hive-txn-schema-3.0.0.derby.sql | 134 + .../derby/upgrade-2.1.0-to-2.2.0.derby.sql | 1 + .../derby/upgrade-2.2.0-to-2.3.0.derby.sql | 4 + .../derby/upgrade-2.3.0-to-3.0.0.derby.sql | 3 + .../scripts/upgrade/derby/upgrade.order.derby | 2 + .../upgrade/mssql/024-HIVE-12274.mssql.sql | 18 + .../upgrade/mssql/025-HIVE-16399.mssql.sql | 1 + .../upgrade/mssql/hive-schema-2.2.0.mssql.sql | 30 +- .../upgrade/mssql/hive-schema-2.3.0.mssql.sql | 1023 + .../upgrade/mssql/hive-schema-3.0.0.mssql.sql | 1023 + .../mssql/hive-txn-schema-0.14.0.mssql.sql | 2 +- .../mssql/upgrade-2.1.0-to-2.2.0.mssql.sql | 1 + .../mssql/upgrade-2.2.0-to-2.3.0.mssql.sql | 6 + .../mssql/upgrade-2.3.0-to-3.0.0.mssql.sql | 4 + .../scripts/upgrade/mssql/upgrade.order.mssql | 2 + .../upgrade/mysql/039-HIVE-12274.mysql.sql | 18 + .../upgrade/mysql/040-HIVE-16399.mysql.sql | 1 + .../upgrade/mysql/hive-schema-2.2.0.mysql.sql | 28 +- .../upgrade/mysql/hive-schema-2.3.0.mysql.sql | 853 + .../upgrade/mysql/hive-schema-3.0.0.mysql.sql | 853 + .../mysql/hive-txn-schema-2.2.0.mysql.sql | 2 +- .../mysql/hive-txn-schema-2.3.0.mysql.sql | 135 + .../mysql/hive-txn-schema-3.0.0.mysql.sql | 135 + .../mysql/upgrade-2.1.0-to-2.2.0.mysql.sql | 1 + .../mysql/upgrade-2.2.0-to-2.3.0.mysql.sql | 7 + .../mysql/upgrade-2.3.0-to-3.0.0.mysql.sql | 5 + .../scripts/upgrade/mysql/upgrade.order.mysql | 2 + .../upgrade/oracle/039-HIVE-12274.oracle.sql | 21 + .../upgrade/oracle/040-HIVE-16399.oracle.sql | 1 + .../upgrade/oracle/hive-schema-2.2.0.oracle.sql | 30 +- .../upgrade/oracle/hive-schema-2.3.0.oracle.sql | 811 + .../upgrade/oracle/hive-schema-3.0.0.oracle.sql | 811 + .../oracle/hive-txn-schema-2.2.0.oracle.sql | 2 +- .../oracle/hive-txn-schema-2.3.0.oracle.sql | 133 + .../oracle/hive-txn-schema-3.0.0.oracle.sql | 133 + .../oracle/upgrade-2.1.0-to-2.2.0.oracle.sql | 1 + .../oracle/upgrade-2.2.0-to-2.3.0.oracle.sql | 6 + .../oracle/upgrade-2.3.0-to-3.0.0.oracle.sql | 4 + .../scripts/upgrade/oracle/upgrade.order.oracle | 2 + .../postgres/038-HIVE-12274.postgres.sql | 18 + .../postgres/039-HIVE-16399.postgres.sql | 1 + .../postgres/hive-schema-2.2.0.postgres.sql | 30 +- .../postgres/hive-schema-2.3.0.postgres.sql | 1478 + .../postgres/hive-schema-3.0.0.postgres.sql | 1478 + .../postgres/hive-txn-schema-2.2.0.postgres.sql | 2 +- .../postgres/hive-txn-schema-2.3.0.postgres.sql | 133 + .../postgres/hive-txn-schema-3.0.0.postgres.sql | 133 + .../upgrade-2.1.0-to-2.2.0.postgres.sql | 1 + .../upgrade-2.2.0-to-2.3.0.postgres.sql | 7 + .../upgrade-2.3.0-to-3.0.0.postgres.sql | 5 + .../upgrade/postgres/upgrade.order.postgres | 2 + .../gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 2499 +- .../gen/thrift/gen-cpp/ThriftHiveMetastore.h | 139 + .../ThriftHiveMetastore_server.skeleton.cpp | 5 + .../gen/thrift/gen-cpp/hive_metastore_types.cpp | 1550 +- .../gen/thrift/gen-cpp/hive_metastore_types.h | 23 +- .../hive/metastore/api/GetOpenTxnsResponse.java | 150 +- .../metastore/api/InsertEventRequestData.java | 127 +- .../hive/metastore/api/ThriftHiveMetastore.java | 3116 +- .../gen-php/metastore/ThriftHiveMetastore.php | 1534 +- .../src/gen/thrift/gen-php/metastore/Types.php | 584 +- .../hive_metastore/ThriftHiveMetastore-remote | 7 + .../hive_metastore/ThriftHiveMetastore.py | 948 +- .../gen/thrift/gen-py/hive_metastore/ttypes.py | 60 +- .../gen/thrift/gen-rb/hive_metastore_types.rb | 13 +- .../gen/thrift/gen-rb/thrift_hive_metastore.rb | 62 + .../hadoop/hive/metastore/HiveAlterHandler.java | 444 +- .../hadoop/hive/metastore/HiveMetaStore.java | 803 +- .../hive/metastore/HiveMetaStoreClient.java | 68 +- .../hive/metastore/HiveMetaStoreFsImpl.java | 21 +- .../hadoop/hive/metastore/IMetaStoreClient.java | 14 + .../hive/metastore/MetaStoreDirectSql.java | 104 +- .../hive/metastore/MetaStoreEventListener.java | 12 +- .../metastore/MetaStoreListenerNotifier.java | 224 + .../hive/metastore/MetaStoreSchemaInfo.java | 16 +- .../hadoop/hive/metastore/MetaStoreUtils.java | 28 +- .../hadoop/hive/metastore/ObjectStore.java | 836 +- .../apache/hadoop/hive/metastore/RawStore.java | 12 + .../hive/metastore/StatObjectConverter.java | 42 +- .../apache/hadoop/hive/metastore/Warehouse.java | 81 +- .../hive/metastore/cache/ByteArrayWrapper.java | 45 + .../hadoop/hive/metastore/cache/CacheUtils.java | 113 + .../hive/metastore/cache/CachedStore.java | 1622 + .../hive/metastore/cache/SharedCache.java | 356 + .../metastore/events/AlterPartitionEvent.java | 14 +- .../hive/metastore/events/AlterTableEvent.java | 12 +- .../hive/metastore/events/InsertEvent.java | 11 + .../hive/metastore/events/ListenerEvent.java | 106 + .../hadoop/hive/metastore/hbase/HBaseStore.java | 29 + .../hadoop/hive/metastore/hbase/HBaseUtils.java | 2 +- .../messaging/AlterPartitionMessage.java | 2 + .../metastore/messaging/AlterTableMessage.java | 2 + .../hive/metastore/messaging/EventUtils.java | 87 +- .../hive/metastore/messaging/InsertMessage.java | 6 + .../metastore/messaging/MessageFactory.java | 9 +- .../metastore/messaging/PartitionFiles.java | 3 + .../messaging/event/filters/AndFilter.java | 39 + .../messaging/event/filters/BasicFilter.java | 33 + .../event/filters/DatabaseAndTableFilter.java | 52 + .../event/filters/EventBoundaryFilter.java | 34 + .../event/filters/MessageFormatFilter.java | 36 + .../json/JSONAlterPartitionMessage.java | 9 +- .../messaging/json/JSONAlterTableMessage.java | 9 +- .../messaging/json/JSONInsertMessage.java | 9 +- .../messaging/json/JSONMessageDeserializer.java | 4 + .../messaging/json/JSONMessageFactory.java | 18 +- .../hive/metastore/parser/ExpressionTree.java | 2 +- .../hadoop/hive/metastore/txn/TxnHandler.java | 115 +- .../hadoop/hive/metastore/txn/TxnUtils.java | 17 +- metastore/src/model/package.jdo | 36 +- .../DummyRawStoreControlledCommit.java | 8 + .../DummyRawStoreForJdoConnection.java | 8 + .../metastore/TestHiveMetaStoreTimeout.java | 1 - .../hadoop/hive/metastore/TestObjectStore.java | 68 + .../hive/metastore/VerifyingObjectStore.java | 2 +- .../hive/metastore/cache/TestCachedStore.java | 238 + .../json/JSONMessageDeserializerTest.java | 106 + .../txn/TestValidCompactorTxnList.java | 63 +- packaging/pom.xml | 2 +- packaging/src/main/assembly/src.xml | 2 +- pom.xml | 126 +- ql/pom.xml | 25 +- .../UDAFTemplates/VectorUDAFAvg.txt | 2 +- .../UDAFTemplates/VectorUDAFMinMax.txt | 2 +- .../UDAFTemplates/VectorUDAFMinMaxDecimal.txt | 2 +- .../VectorUDAFMinMaxIntervalDayTime.txt | 2 +- .../UDAFTemplates/VectorUDAFMinMaxString.txt | 4 +- .../UDAFTemplates/VectorUDAFMinMaxTimestamp.txt | 2 +- .../UDAFTemplates/VectorUDAFSum.txt | 2 +- .../UDAFTemplates/VectorUDAFVar.txt | 2 +- .../UDAFTemplates/VectorUDAFVarDecimal.txt | 4 +- .../java/org/apache/hadoop/hive/ql/Context.java | 11 +- .../java/org/apache/hadoop/hive/ql/Driver.java | 425 +- .../org/apache/hadoop/hive/ql/ErrorMsg.java | 21 +- .../hadoop/hive/ql/QueryLifeTimeHookRunner.java | 186 + .../org/apache/hadoop/hive/ql/QueryPlan.java | 28 +- .../hadoop/hive/ql/exec/ArchiveUtils.java | 7 +- .../apache/hadoop/hive/ql/exec/ColumnInfo.java | 7 +- .../hadoop/hive/ql/exec/ColumnStatsTask.java | 32 +- .../apache/hadoop/hive/ql/exec/CopyTask.java | 3 +- .../org/apache/hadoop/hive/ql/exec/DDLTask.java | 106 +- .../apache/hadoop/hive/ql/exec/ExplainTask.java | 11 +- .../exec/ExprNodeConstantDefaultEvaluator.java | 55 - .../hive/ql/exec/ExprNodeEvaluatorFactory.java | 6 - .../hadoop/hive/ql/exec/FetchOperator.java | 16 + .../hadoop/hive/ql/exec/FileSinkOperator.java | 16 +- .../hadoop/hive/ql/exec/FunctionRegistry.java | 37 +- .../hadoop/hive/ql/exec/GroupByOperator.java | 5 +- .../apache/hadoop/hive/ql/exec/MoveTask.java | 7 +- .../hadoop/hive/ql/exec/OperatorFactory.java | 20 +- .../hadoop/hive/ql/exec/ReplCopyTask.java | 3 +- .../hive/ql/exec/SerializationUtilities.java | 30 + .../hadoop/hive/ql/exec/StatsNoJobTask.java | 15 +- .../apache/hadoop/hive/ql/exec/TaskRunner.java | 7 - .../apache/hadoop/hive/ql/exec/TopNHash.java | 5 +- .../apache/hadoop/hive/ql/exec/Utilities.java | 34 +- .../mapjoin/MapJoinMemoryExhaustionError.java | 28 + .../MapJoinMemoryExhaustionException.java | 29 - .../mapjoin/MapJoinMemoryExhaustionHandler.java | 6 +- .../hadoop/hive/ql/exec/mr/ExecDriver.java | 44 +- .../hadoop/hive/ql/exec/mr/MapredLocalTask.java | 19 +- .../persistence/BytesBytesMultiHashMap.java | 17 +- .../ql/exec/persistence/HashMapWrapper.java | 10 +- .../persistence/HybridHashTableContainer.java | 5 + .../persistence/MapJoinBytesTableContainer.java | 58 +- .../exec/persistence/MapJoinTableContainer.java | 3 +- .../ql/exec/spark/RemoteHiveSparkClient.java | 9 +- .../hive/ql/exec/spark/SparkPlanGenerator.java | 23 +- .../ql/exec/spark/SparkReduceRecordHandler.java | 6 +- .../hadoop/hive/ql/exec/spark/SparkTask.java | 27 +- .../hive/ql/exec/spark/SparkUtilities.java | 4 +- .../spark/status/RemoteSparkJobMonitor.java | 15 +- .../ql/exec/spark/status/SparkJobMonitor.java | 10 +- .../spark/status/impl/RemoteSparkJobStatus.java | 6 + .../hadoop/hive/ql/exec/tez/DagUtils.java | 38 +- .../hive/ql/exec/tez/HashTableLoader.java | 42 +- .../hive/ql/exec/tez/ReduceRecordSource.java | 11 +- .../hadoop/hive/ql/exec/tez/TezProcessor.java | 11 +- .../hive/ql/exec/tez/TezSessionPoolManager.java | 21 +- .../hive/ql/exec/tez/TezSessionState.java | 4 + .../apache/hadoop/hive/ql/exec/tez/TezTask.java | 18 +- .../hive/ql/exec/tez/monitoring/Constants.java | 17 + .../hive/ql/exec/tez/monitoring/DAGSummary.java | 72 +- .../exec/tez/monitoring/FSCountersSummary.java | 17 + .../ql/exec/tez/monitoring/LLAPioSummary.java | 17 + .../ql/exec/tez/monitoring/PrintSummary.java | 17 + .../QueryExecutionBreakdownSummary.java | 17 + .../ql/exec/tez/monitoring/RenderStrategy.java | 21 +- .../exec/tez/monitoring/TezProgressMonitor.java | 17 + .../vector/VectorAggregationBufferBatch.java | 4 +- .../ql/exec/vector/VectorColumnSetInfo.java | 158 +- .../hive/ql/exec/vector/VectorExtractRow.java | 19 + .../ql/exec/vector/VectorGroupByOperator.java | 164 +- .../ql/exec/vector/VectorGroupKeyHelper.java | 57 +- .../ql/exec/vector/VectorHashKeyWrapper.java | 244 +- .../exec/vector/VectorHashKeyWrapperBatch.java | 456 +- .../ql/exec/vector/VectorMapJoinOperator.java | 3 + .../exec/vector/VectorSMBMapJoinOperator.java | 3 + .../ql/exec/vector/VectorizationContext.java | 52 +- .../vector/expressions/CastStringToLong.java | 271 + .../exec/vector/expressions/CuckooSetBytes.java | 4 +- .../ql/exec/vector/expressions/OctetLength.java | 149 + .../aggregates/VectorAggregateExpression.java | 2 +- .../aggregates/VectorUDAFAvgDecimal.java | 2 +- .../aggregates/VectorUDAFAvgTimestamp.java | 2 +- .../aggregates/VectorUDAFBloomFilter.java | 4 +- .../aggregates/VectorUDAFBloomFilterMerge.java | 2 +- .../expressions/aggregates/VectorUDAFCount.java | 2 +- .../aggregates/VectorUDAFCountMerge.java | 2 +- .../aggregates/VectorUDAFCountStar.java | 2 +- .../aggregates/VectorUDAFStdPopTimestamp.java | 2 +- .../aggregates/VectorUDAFStdSampTimestamp.java | 2 +- .../aggregates/VectorUDAFSumDecimal.java | 2 +- .../aggregates/VectorUDAFVarPopTimestamp.java | 2 +- .../aggregates/VectorUDAFVarSampTimestamp.java | 2 +- .../VectorMapJoinGenerateResultOperator.java | 2 + .../fast/VectorMapJoinFastBytesHashMap.java | 5 + .../VectorMapJoinFastBytesHashMultiSet.java | 5 + .../fast/VectorMapJoinFastBytesHashSet.java | 5 + .../fast/VectorMapJoinFastBytesHashTable.java | 6 + .../fast/VectorMapJoinFastHashTable.java | 13 +- .../fast/VectorMapJoinFastHashTableLoader.java | 47 +- .../mapjoin/fast/VectorMapJoinFastKeyStore.java | 11 +- .../fast/VectorMapJoinFastLongHashMap.java | 9 +- .../fast/VectorMapJoinFastLongHashMultiSet.java | 5 + .../fast/VectorMapJoinFastLongHashSet.java | 5 + .../fast/VectorMapJoinFastLongHashTable.java | 15 + .../fast/VectorMapJoinFastMultiKeyHashMap.java | 5 + .../VectorMapJoinFastMultiKeyHashMultiSet.java | 4 + .../fast/VectorMapJoinFastMultiKeyHashSet.java | 5 +- .../fast/VectorMapJoinFastStringHashMap.java | 9 + .../VectorMapJoinFastStringHashMultiSet.java | 8 + .../fast/VectorMapJoinFastStringHashSet.java | 8 + .../fast/VectorMapJoinFastTableContainer.java | 16 +- .../fast/VectorMapJoinFastValueStore.java | 8 +- .../hashtable/VectorMapJoinHashTable.java | 3 +- .../VectorMapJoinOptimizedHashSet.java | 5 + .../VectorMapJoinOptimizedHashTable.java | 9 + .../VectorMapJoinOptimizedStringHashSet.java | 8 + .../VectorReduceSinkCommonOperator.java | 173 +- .../VectorReduceSinkLongOperator.java | 2 +- .../VectorReduceSinkMultiKeyOperator.java | 2 +- .../VectorReduceSinkObjectHashOperator.java | 289 + .../VectorReduceSinkStringOperator.java | 2 +- .../VectorReduceSinkUniformHashOperator.java | 218 + .../hadoop/hive/ql/history/HiveHistoryImpl.java | 5 +- .../apache/hadoop/hive/ql/hooks/HookUtils.java | 52 +- .../hadoop/hive/ql/hooks/HooksLoader.java | 107 + .../hadoop/hive/ql/hooks/LineageInfo.java | 3 +- .../hooks/PostExecOrcRowGroupCountPrinter.java | 4 +- .../ql/hooks/PostExecTezSummaryPrinter.java | 12 +- .../hive/ql/hooks/PostExecutePrinter.java | 6 +- .../hadoop/hive/ql/hooks/PreExecutePrinter.java | 6 +- .../ql/hooks/QueryLifeTimeHookContextImpl.java | 34 +- .../hooks/QueryLifeTimeHookWithParseHooks.java | 41 + .../apache/hadoop/hive/ql/index/HiveIndex.java | 4 +- .../hive/ql/io/CombineHiveInputFormat.java | 7 + .../hadoop/hive/ql/io/HiveFileFormatUtils.java | 2 +- .../hadoop/hive/ql/io/HiveInputFormat.java | 3 +- .../org/apache/hadoop/hive/ql/io/RCFile.java | 2 +- .../apache/hadoop/hive/ql/io/orc/OrcFile.java | 4 +- .../hadoop/hive/ql/io/orc/OrcInputFormat.java | 8 +- .../ql/io/orc/encoded/EncodedReaderImpl.java | 216 +- .../io/parquet/MapredParquetOutputFormat.java | 10 +- .../ql/io/parquet/ParquetRecordReaderBase.java | 14 +- .../ql/io/parquet/timestamp/NanoTimeUtils.java | 15 +- .../vector/VectorizedParquetRecordReader.java | 5 +- .../ql/io/rcfile/stats/PartialScanTask.java | 6 +- .../hadoop/hive/ql/lockmgr/DbTxnManager.java | 282 +- .../hadoop/hive/ql/lockmgr/DummyTxnManager.java | 3 +- .../hadoop/hive/ql/lockmgr/HiveLockObject.java | 18 +- .../hadoop/hive/ql/lockmgr/HiveTxnManager.java | 16 +- .../hive/ql/lockmgr/HiveTxnManagerImpl.java | 25 +- .../zookeeper/ZooKeeperHiveLockManager.java | 39 +- .../hadoop/hive/ql/log/LogDivertAppender.java | 249 + .../hive/ql/log/LogDivertAppenderForTest.java | 182 + .../apache/hadoop/hive/ql/metadata/Hive.java | 272 +- .../metadata/HiveMaterializedViewsRegistry.java | 3 +- .../hive/ql/metadata/HiveMetaStoreChecker.java | 102 +- .../ql/metadata/SessionHiveMetaStoreClient.java | 2 +- .../apache/hadoop/hive/ql/metadata/Table.java | 24 +- .../hadoop/hive/ql/metadata/VirtualColumn.java | 2 +- .../hadoop/hive/ql/optimizer/ColumnPruner.java | 13 +- .../ql/optimizer/ColumnPrunerProcFactory.java | 36 +- .../hive/ql/optimizer/ConvertJoinMapJoin.java | 86 +- .../DynamicPartitionPruningOptimization.java | 183 +- .../hive/ql/optimizer/GenMRFileSink1.java | 11 +- .../hive/ql/optimizer/GenMapRedUtils.java | 6 +- .../hive/ql/optimizer/MapJoinProcessor.java | 8 +- .../hadoop/hive/ql/optimizer/Optimizer.java | 2 +- .../ql/optimizer/SetReducerParallelism.java | 2 + .../calcite/CalciteSemanticException.java | 5 +- .../ql/optimizer/calcite/HiveCalciteUtil.java | 6 + .../optimizer/calcite/HivePlannerContext.java | 9 +- .../optimizer/calcite/HiveRelShuttleImpl.java | 5 + .../calcite/reloperators/HiveExtractDate.java | 8 +- .../HiveDruidProjectFilterTransposeRule.java | 48 + .../calcite/rules/HiveFilterJoinRule.java | 51 - .../rules/HivePointLookupOptimizerRule.java | 95 +- .../rules/HiveProjectSortTransposeRule.java | 20 +- .../rules/HiveSortProjectTransposeRule.java | 48 +- .../calcite/rules/HiveSubQueryRemoveRule.java | 194 +- .../HiveMaterializedViewFilterScanRule.java | 3 +- .../stats/FilterSelectivityEstimator.java | 12 + .../calcite/stats/HiveRelMdPredicates.java | 14 +- .../calcite/translator/ASTBuilder.java | 14 +- .../calcite/translator/ASTConverter.java | 1 - .../calcite/translator/ExprNodeConverter.java | 18 +- .../calcite/translator/HiveOpConverter.java | 21 +- .../calcite/translator/RexNodeConverter.java | 83 +- .../translator/SqlFunctionConverter.java | 1 + .../correlation/ReduceSinkDeDuplication.java | 2 +- .../ListBucketingPrunerUtils.java | 4 +- .../physical/GenMRSkewJoinProcessor.java | 13 +- .../physical/GenSparkSkewJoinProcessor.java | 3 +- .../physical/LlapClusterStateForCompile.java | 132 + .../hive/ql/optimizer/physical/LlapDecider.java | 56 +- .../physical/LlapPreVectorizationPass.java | 128 + .../optimizer/physical/NullScanOptimizer.java | 58 +- .../hive/ql/optimizer/physical/Vectorizer.java | 333 +- .../ql/optimizer/physical/VectorizerReason.java | 2 +- .../hive/ql/optimizer/ppr/PartitionPruner.java | 3 +- .../optimizer/spark/SparkMapJoinOptimizer.java | 73 +- .../stats/annotation/StatsRulesProcFactory.java | 16 +- .../hive/ql/parse/BaseSemanticAnalyzer.java | 8 +- .../hadoop/hive/ql/parse/CalcitePlanner.java | 221 +- .../ql/parse/ColumnStatsSemanticAnalyzer.java | 19 +- .../hive/ql/parse/DDLSemanticAnalyzer.java | 31 +- .../apache/hadoop/hive/ql/parse/EximUtil.java | 256 +- .../hive/ql/parse/ExplainSemanticAnalyzer.java | 22 +- .../hive/ql/parse/ExportSemanticAnalyzer.java | 4 +- .../hadoop/hive/ql/parse/FromClauseParser.g | 3 +- .../hive/ql/parse/FunctionSemanticAnalyzer.java | 8 +- .../hadoop/hive/ql/parse/GenTezUtils.java | 33 +- .../apache/hadoop/hive/ql/parse/GenTezWork.java | 3 +- .../apache/hadoop/hive/ql/parse/HintParser.g | 4 + .../org/apache/hadoop/hive/ql/parse/HiveLexer.g | 3 +- .../apache/hadoop/hive/ql/parse/HiveParser.g | 2 + .../hadoop/hive/ql/parse/IdentifiersParser.g | 23 +- .../hive/ql/parse/ImportSemanticAnalyzer.java | 101 +- .../hadoop/hive/ql/parse/NamedJoinInfo.java | 65 + .../hadoop/hive/ql/parse/ParseContext.java | 44 +- .../apache/hadoop/hive/ql/parse/ParseUtils.java | 1 + .../hive/ql/parse/ProcessAnalyzeTable.java | 6 +- .../apache/hadoop/hive/ql/parse/QBJoinTree.java | 16 + .../hadoop/hive/ql/parse/QBParseInfo.java | 9 + .../ql/parse/ReplicationSemanticAnalyzer.java | 737 +- .../hadoop/hive/ql/parse/ReplicationSpec.java | 22 +- .../hadoop/hive/ql/parse/RowResolver.java | 10 + .../hadoop/hive/ql/parse/RuntimeValuesInfo.java | 10 + .../hadoop/hive/ql/parse/SemanticAnalyzer.java | 337 +- .../hive/ql/parse/SemanticAnalyzerFactory.java | 23 +- .../hive/ql/parse/SemiJoinBranchInfo.java | 45 + .../hadoop/hive/ql/parse/SemiJoinHint.java | 43 + .../hadoop/hive/ql/parse/SubQueryUtils.java | 21 +- .../hadoop/hive/ql/parse/TaskCompiler.java | 6 +- .../hadoop/hive/ql/parse/TezCompiler.java | 512 +- .../hive/ql/parse/TypeCheckProcFactory.java | 5 +- .../ql/parse/UpdateDeleteSemanticAnalyzer.java | 14 + .../hadoop/hive/ql/parse/WindowingSpec.java | 2 +- .../hadoop/hive/ql/parse/repl/DumpType.java | 45 + .../dump/BootStrapReplicationSpecFunction.java | 54 + .../hive/ql/parse/repl/dump/HiveWrapper.java | 73 + .../hadoop/hive/ql/parse/repl/dump/Utils.java | 50 + .../ql/parse/repl/dump/io/DBSerializer.java | 55 + .../parse/repl/dump/io/FunctionSerializer.java | 49 + .../hive/ql/parse/repl/dump/io/JsonWriter.java | 55 + .../parse/repl/dump/io/PartitionSerializer.java | 65 + .../repl/dump/io/ReplicationSpecSerializer.java | 36 + .../ql/parse/repl/dump/io/TableSerializer.java | 114 + .../dump/io/VersionCompatibleSerializer.java | 37 + .../ql/parse/repl/events/AbstractHandler.java | 46 + .../parse/repl/events/AddPartitionHandler.java | 114 + .../repl/events/AlterPartitionHandler.java | 112 + .../ql/parse/repl/events/AlterTableHandler.java | 102 + .../parse/repl/events/CreateTableHandler.java | 86 + .../ql/parse/repl/events/DefaultHandler.java | 44 + .../parse/repl/events/DropPartitionHandler.java | 44 + .../ql/parse/repl/events/DropTableHandler.java | 44 + .../hive/ql/parse/repl/events/EventHandler.java | 62 + .../parse/repl/events/EventHandlerFactory.java | 75 + .../ql/parse/repl/events/InsertHandler.java | 110 + .../hive/ql/parse/repl/load/DumpMetaData.java | 143 + .../hive/ql/parse/repl/load/MetaData.java | 64 + .../hive/ql/parse/repl/load/MetadataJson.java | 128 + .../parse/spark/SparkProcessAnalyzeTable.java | 5 +- .../hadoop/hive/ql/plan/AbstractVectorDesc.java | 4 +- .../hadoop/hive/ql/plan/AlterTableDesc.java | 6 + .../hadoop/hive/ql/plan/CreateTableDesc.java | 3 +- .../hadoop/hive/ql/plan/CreateViewDesc.java | 22 + .../ql/plan/ExprNodeConstantDefaultDesc.java | 86 - .../hive/ql/plan/ExprNodeConstantDesc.java | 6 +- .../hadoop/hive/ql/plan/ExprNodeDescUtils.java | 71 + .../hive/ql/plan/ExprNodeDynamicListDesc.java | 9 +- .../apache/hadoop/hive/ql/plan/GroupByDesc.java | 2 +- .../hadoop/hive/ql/plan/HiveOperation.java | 37 +- .../hadoop/hive/ql/plan/ImportTableDesc.java | 321 + .../apache/hadoop/hive/ql/plan/JoinDesc.java | 18 +- .../apache/hadoop/hive/ql/plan/MapJoinDesc.java | 18 +- .../hadoop/hive/ql/plan/PartitionDesc.java | 28 +- .../hadoop/hive/ql/plan/ReduceSinkDesc.java | 29 +- .../apache/hadoop/hive/ql/plan/ReduceWork.java | 67 + .../apache/hadoop/hive/ql/plan/SparkWork.java | 10 +- .../apache/hadoop/hive/ql/plan/TableDesc.java | 4 +- .../hadoop/hive/ql/plan/TezEdgeProperty.java | 18 +- .../hive/ql/plan/VectorAppMasterEventDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorFileSinkDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorFilterDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorGroupByDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorLimitDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorMapJoinDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorMapJoinInfo.java | 2 +- .../hive/ql/plan/VectorPartitionDesc.java | 2 +- .../hive/ql/plan/VectorReduceSinkDesc.java | 23 +- .../hive/ql/plan/VectorReduceSinkInfo.java | 98 +- .../hadoop/hive/ql/plan/VectorSMBJoinDesc.java | 2 +- .../hadoop/hive/ql/plan/VectorSelectDesc.java | 2 +- .../ql/plan/VectorSparkHashTableSinkDesc.java | 2 +- .../VectorSparkPartitionPruningSinkDesc.java | 2 +- .../hive/ql/plan/VectorTableScanDesc.java | 2 +- .../hive/ql/ppd/SyntheticJoinPredicate.java | 2 - .../ql/processors/CommandProcessorResponse.java | 10 +- .../hadoop/hive/ql/processors/HiveCommand.java | 2 +- .../hive/ql/processors/ResetProcessor.java | 21 +- .../hadoop/hive/ql/processors/SetProcessor.java | 15 +- .../plugin/sqlstd/SQLAuthorizationUtils.java | 4 +- .../hadoop/hive/ql/session/OperationLog.java | 127 +- .../hadoop/hive/ql/session/SessionState.java | 25 +- .../apache/hadoop/hive/ql/stats/StatsUtils.java | 47 +- .../hadoop/hive/ql/txn/compactor/Cleaner.java | 3 +- .../hive/ql/txn/compactor/CompactorMR.java | 10 +- .../org/apache/hadoop/hive/ql/udf/UDFJson.java | 67 +- .../apache/hadoop/hive/ql/udf/UDFLength.java | 66 - .../apache/hadoop/hive/ql/udf/UDFToBoolean.java | 3 +- .../apache/hadoop/hive/ql/udf/UDFToByte.java | 3 +- .../apache/hadoop/hive/ql/udf/UDFToInteger.java | 3 +- .../apache/hadoop/hive/ql/udf/UDFToLong.java | 3 +- .../apache/hadoop/hive/ql/udf/UDFToShort.java | 3 +- .../generic/GenericUDAFBinarySetFunctions.java | 452 + .../ql/udf/generic/GenericUDAFBloomFilter.java | 33 + .../ql/udf/generic/GenericUDAFComputeStats.java | 22 +- .../ql/udf/generic/GenericUDAFCorrelation.java | 26 +- .../generic/GenericUDAFCovarianceSample.java | 18 +- .../hadoop/hive/ql/udf/generic/GenericUDF.java | 3 +- .../udf/generic/GenericUDFCharacterLength.java | 120 + .../ql/udf/generic/GenericUDFExtractUnion.java | 272 + .../hive/ql/udf/generic/GenericUDFGrouping.java | 45 +- .../hive/ql/udf/generic/GenericUDFInFile.java | 3 +- .../udf/generic/GenericUDFInternalInterval.java | 4 +- .../hive/ql/udf/generic/GenericUDFLength.java | 129 + .../hive/ql/udf/generic/GenericUDFLikeAll.java | 133 + .../hive/ql/udf/generic/GenericUDFLikeAny.java | 134 + .../hive/ql/udf/generic/GenericUDFOPEqual.java | 9 - .../ql/udf/generic/GenericUDFOPNotEqual.java | 9 - .../ql/udf/generic/GenericUDFOctetLength.java | 114 + .../hive/ql/udf/generic/GenericUDFTrunc.java | 10 +- .../ql/udf/generic/GenericUDFWidthBucket.java | 329 + .../hive/metastore/txn/TestTxnHandler.java | 2 +- .../org/apache/hadoop/hive/ql/TestErrorMsg.java | 6 +- .../apache/hadoop/hive/ql/TestTxnCommands.java | 49 +- .../apache/hadoop/hive/ql/TestTxnCommands2.java | 24 +- .../ql/TestTxnCommands2WithSplitUpdate.java | 61 +- .../hadoop/hive/ql/exec/TestOperators.java | 72 +- .../TestMapJoinMemoryExhaustionHandler.java | 4 +- .../tez/monitoring/TestTezProgressMonitor.java | 17 + .../hive/ql/exec/vector/TestVectorSerDeRow.java | 5 +- .../mapjoin/fast/CheckFastRowHashMap.java | 17 +- .../mapjoin/fast/CommonFastHashTable.java | 4 +- .../hadoop/hive/ql/hooks/TestQueryHooks.java | 162 +- .../hadoop/hive/ql/io/orc/TestOrcFile.java | 17 +- .../hive/ql/io/orc/TestOrcRawRecordMerger.java | 7 +- .../io/parquet/timestamp/TestNanoTimeUtils.java | 13 + .../hive/ql/lockmgr/TestDbTxnManager.java | 65 +- .../hive/ql/lockmgr/TestDbTxnManager2.java | 376 +- .../hive/ql/lockmgr/TestDummyTxnManager.java | 4 +- .../ql/lockmgr/TestEmbeddedLockManager.java | 4 +- .../hive/ql/lockmgr/TestHiveLockObject.java | 30 +- .../zookeeper/TestZookeeperLockManager.java | 2 +- .../hadoop/hive/ql/metadata/TestHive.java | 2 +- .../ql/metadata/TestHiveMetaStoreChecker.java | 207 +- .../calcite/TestCBORuleFiredOnlyOnce.java | 2 +- .../hive/ql/parse/TestHiveDecimalParse.java | 23 +- .../parse/TestReplicationSemanticAnalyzer.java | 22 +- .../ql/parse/repl/dump/HiveWrapperTest.java | 27 + .../repl/events/TestEventHandlerFactory.java | 62 + .../hive/ql/processors/TestResetProcessor.java | 59 + .../hive/ql/txn/compactor/TestInitiator.java | 11 +- .../TestGenericUDAFBinarySetFunctions.java | 414 + .../udf/generic/TestGenericUDFExtractUnion.java | 175 + ...UDFExtractUnionObjectInspectorConverter.java | 109 + ...estGenericUDFExtractUnionValueConverter.java | 108 + .../ql/udf/generic/TestGenericUDFLikeAll.java | 88 + .../ql/udf/generic/TestGenericUDFLikeAny.java | 87 + .../ql/udf/generic/TestGenericUDFTrunc.java | 283 + .../udf/generic/TestGenericUDFWidthBucket.java | 86 + .../clientnegative/bucket_mapjoin_mismatch1.q | 1 + .../bucket_mapjoin_wrong_table_metadata_1.q | 2 +- .../bucket_mapjoin_wrong_table_metadata_2.q | 1 + .../clientnegative/char_pad_convert_fail0.q | 4 +- .../clientnegative/char_pad_convert_fail1.q | 4 +- .../clientnegative/char_pad_convert_fail2.q | 4 +- .../clientnegative/char_pad_convert_fail3.q | 4 +- ...umnstats_partlvl_invalid_values_autogather.q | 17 + .../queries/clientnegative/decimal_precision.q | 4 +- .../clientnegative/decimal_precision_1.q | 4 +- .../distinct_windowing_failure1.q | 2 +- .../distinct_windowing_failure2.q | 2 +- .../drop_default_partition_filter.q | 7 + .../queries/clientnegative/invalid_mapjoin1.q | 1 + ql/src/test/queries/clientnegative/join2.q | 1 + ql/src/test/queries/clientnegative/join28.q | 2 +- ql/src/test/queries/clientnegative/join29.q | 2 +- ql/src/test/queries/clientnegative/join32.q | 1 + ql/src/test/queries/clientnegative/join35.q | 2 +- .../test/queries/clientnegative/msck_repair_4.q | 14 + .../queries/clientnegative/nvl_mismatch_type.q | 2 +- .../queries/clientnegative/smb_bucketmapjoin.q | 2 +- .../queries/clientnegative/smb_mapjoin_14.q | 2 +- .../sortmerge_mapjoin_mismatch_1.q | 3 +- .../clientnegative/spark_job_max_tasks.q | 6 + .../subquery_scalar_corr_multi_rows.q | 2 + .../subquery_select_complex_expr.q | 3 - .../clientnegative/subquery_select_no_source.q | 2 + .../clientnegative/subquery_select_udf.q | 2 - .../clientnegative/subquery_with_or_cond.q | 5 - .../queries/clientnegative/udf_likeall_wrong1.q | 2 + .../queries/clientnegative/udf_likeany_wrong1.q | 2 + ql/src/test/queries/clientnegative/union22.q | 2 +- .../clientpositive/alter_table_column_stats.q | 241 + .../alter_table_invalidate_column_stats.q | 153 - .../annotate_stats_deep_filters.q | 2 +- .../clientpositive/auto_sortmerge_join_11.q | 2 +- .../test/queries/clientpositive/avro_decimal.q | 14 +- .../clientpositive/avro_decimal_native.q | 14 +- .../queries/clientpositive/bucket_map_join_1.q | 2 +- .../queries/clientpositive/bucket_map_join_2.q | 2 +- .../queries/clientpositive/bucketcontext_1.q | 2 +- .../queries/clientpositive/bucketcontext_2.q | 2 +- .../queries/clientpositive/bucketcontext_3.q | 2 +- .../queries/clientpositive/bucketcontext_4.q | 2 +- .../queries/clientpositive/bucketcontext_5.q | 2 +- .../queries/clientpositive/bucketcontext_6.q | 2 +- .../queries/clientpositive/bucketcontext_7.q | 2 +- .../queries/clientpositive/bucketcontext_8.q | 2 +- .../queries/clientpositive/bucketmapjoin10.q | 2 +- .../queries/clientpositive/bucketmapjoin11.q | 2 +- .../queries/clientpositive/bucketmapjoin12.q | 2 +- .../queries/clientpositive/bucketmapjoin13.q | 2 +- .../queries/clientpositive/bucketmapjoin5.q | 2 +- .../queries/clientpositive/bucketmapjoin7.q | 1 + .../queries/clientpositive/bucketmapjoin8.q | 2 +- .../queries/clientpositive/bucketmapjoin9.q | 1 + .../clientpositive/bucketmapjoin_negative.q | 1 + .../clientpositive/bucketmapjoin_negative2.q | 2 +- .../clientpositive/bucketmapjoin_negative3.q | 2 +- ql/src/test/queries/clientpositive/cbo_rp_gby.q | 1 - .../test/queries/clientpositive/cbo_rp_join.q | 1 - .../test/queries/clientpositive/cbo_rp_limit.q | 1 - .../queries/clientpositive/cbo_rp_semijoin.q | 1 - .../clientpositive/cbo_rp_unionDistinct_2.q | 1 + .../test/queries/clientpositive/cbo_rp_views.q | 7 +- .../queries/clientpositive/cbo_rp_windowing_2.q | 6 +- .../queries/clientpositive/char_pad_convert.q | 12 +- ...umn_names_with_leading_and_trailing_spaces.q | 5 + .../column_pruner_multiple_children.q | 19 + .../clientpositive/columnstats_infinity.q | 44 + ql/src/test/queries/clientpositive/comments.q | 4 +- .../clientpositive/correlated_join_keys.q | 34 + .../clientpositive/create_with_constraints.q | 24 +- .../test/queries/clientpositive/decimal_10_0.q | 6 +- .../queries/clientpositive/decimal_precision.q | 28 +- .../queries/clientpositive/distinct_windowing.q | 2 +- .../clientpositive/distinct_windowing_no_cbo.q | 2 +- .../clientpositive/drop_partitions_filter4.q | 10 + .../test/queries/clientpositive/druid_basic2.q | 24 + .../clientpositive/dynamic_partition_pruning.q | 3 +- .../clientpositive/dynamic_semijoin_reduction.q | 20 +- .../dynamic_semijoin_reduction_2.q | 3 + .../dynamic_semijoin_reduction_3.q | 79 + .../dynamic_semijoin_user_level.q | 107 + .../dynpart_sort_opt_vectorization.q | 2 +- .../clientpositive/dynpart_sort_optimization.q | 2 +- .../encryption_auto_purge_tables.q | 38 + .../clientpositive/encryption_drop_partition.q | 7 +- .../clientpositive/encryption_drop_table.q | 12 +- .../encryption_drop_table_in_encrypted_db.q | 20 + .../clientpositive/encryption_move_tbl.q | 8 +- .../test/queries/clientpositive/explainuser_4.q | 1 + .../clientpositive/fp_literal_arithmetic.q | 57 + .../clientpositive/groupby_grouping_id1.q | 2 + .../clientpositive/groupby_grouping_id2.q | 4 + .../clientpositive/groupby_grouping_id3.q | 12 + .../clientpositive/groupby_grouping_sets1.q | 20 + .../clientpositive/groupby_grouping_sets2.q | 4 + .../clientpositive/groupby_grouping_sets3.q | 6 + .../clientpositive/groupby_grouping_sets4.q | 1 + .../clientpositive/groupby_grouping_sets5.q | 2 + .../clientpositive/groupby_grouping_sets6.q | 2 + .../groupby_grouping_sets_grouping.q | 39 + .../groupby_grouping_sets_limit.q | 3 + .../infer_bucket_sort_map_operators.q | 1 + .../queries/clientpositive/inputwherefalse.q | 19 + .../queries/clientpositive/is_distinct_from.q | 46 + .../test/queries/clientpositive/jdbc_handler.q | 1 + ql/src/test/queries/clientpositive/join25.q | 2 +- ql/src/test/queries/clientpositive/join26.q | 1 + ql/src/test/queries/clientpositive/join27.q | 2 +- ql/src/test/queries/clientpositive/join30.q | 2 +- ql/src/test/queries/clientpositive/join36.q | 2 +- ql/src/test/queries/clientpositive/join37.q | 1 + ql/src/test/queries/clientpositive/join38.q | 1 + ql/src/test/queries/clientpositive/join39.q | 1 + ql/src/test/queries/clientpositive/join40.q | 1 + .../clientpositive/join_is_not_distinct_from.q | 71 + .../test/queries/clientpositive/join_map_ppr.q | 1 + .../queries/clientpositive/join_on_varchar.q | 1 + .../test/queries/clientpositive/join_reorder.q | 1 + .../test/queries/clientpositive/join_reorder2.q | 1 + .../test/queries/clientpositive/join_reorder3.q | 2 +- .../test/queries/clientpositive/join_reorder4.q | 2 +- .../clientpositive/lateral_view_onview.q | 6 + ql/src/test/queries/clientpositive/llap_text.q | 2 +- .../clientpositive/llap_vector_nohybridgrace.q | 32 + ql/src/test/queries/clientpositive/mapjoin1.q | 2 + .../queries/clientpositive/mapjoin_decimal.q | 16 +- .../queries/clientpositive/mapjoin_distinct.q | 1 + ql/src/test/queries/clientpositive/mergejoin.q | 2 + .../clientpositive/metadata_only_queries.q | 6 +- .../metadata_only_queries_with_filters.q | 8 +- ql/src/test/queries/clientpositive/mm_all.q | 22 +- .../test/queries/clientpositive/msck_repair_0.q | 7 + .../queries/clientpositive/named_column_join.q | 52 + .../clientpositive/optimize_filter_literal.q | 49 + .../test/queries/clientpositive/orc_file_dump.q | 6 +- .../queries/clientpositive/orc_llap_counters.q | 10 +- .../queries/clientpositive/orc_llap_counters1.q | 10 +- .../test/queries/clientpositive/orc_ppd_basic.q | 10 +- .../clientpositive/orc_ppd_schema_evol_3a.q | 10 +- .../clientpositive/orc_predicate_pushdown.q | 4 +- .../clientpositive/outer_reference_windowed.q | 80 + .../queries/clientpositive/parallel_colstats.q | 32 + .../queries/clientpositive/parquet_decimal.q | 12 +- .../clientpositive/parquet_int96_timestamp.q | 2 +- .../clientpositive/parquet_ppd_multifiles.q | 6 +- .../clientpositive/parquet_predicate_pushdown.q | 6 +- .../clientpositive/partitions_filter_default.q | 14 + ql/src/test/queries/clientpositive/pcs.q | 3 +- .../test/queries/clientpositive/perf/query9.q | 50 + .../clientpositive/position_alias_test_1.q | 5 +- .../queries/clientpositive/primitive_types.q | 4 +- .../queries/clientpositive/quotedid_stats.q | 11 + .../clientpositive/rename_partition_location.q | 14 + ql/src/test/queries/clientpositive/row__id.q | 4 +- .../clientpositive/schema_evol_orc_acid_part.q | 15 +- .../schema_evol_orc_acid_part_update.q | 3 +- .../clientpositive/schema_evol_orc_acid_table.q | 9 +- .../schema_evol_orc_acid_table_update.q | 3 +- .../schema_evol_orc_acidvec_part.q | 46 +- .../schema_evol_orc_acidvec_part_update.q | 3 +- .../schema_evol_orc_acidvec_table.q | 48 +- .../schema_evol_orc_acidvec_table_update.q | 3 +- .../schema_evol_orc_nonvec_part.q | 22 +- .../schema_evol_orc_nonvec_part_all_complex.q | 10 +- .../schema_evol_orc_nonvec_part_all_primitive.q | 14 +- .../schema_evol_orc_nonvec_table.q | 14 +- .../clientpositive/schema_evol_orc_vec_part.q | 2 +- .../schema_evol_orc_vec_part_all_complex.q | 2 +- .../schema_evol_orc_vec_part_all_primitive.q | 2 +- .../clientpositive/schema_evol_orc_vec_table.q | 2 +- .../schema_evol_text_nonvec_part.q | 22 +- .../schema_evol_text_nonvec_part_all_complex.q | 10 +- ...schema_evol_text_nonvec_part_all_primitive.q | 14 +- .../schema_evol_text_nonvec_table.q | 14 +- .../clientpositive/schema_evol_text_vec_part.q | 2 +- .../schema_evol_text_vec_part_all_complex.q | 2 +- .../schema_evol_text_vec_part_all_primitive.q | 2 +- .../clientpositive/schema_evol_text_vec_table.q | 2 +- .../schema_evol_text_vecrow_part.q | 2 +- .../schema_evol_text_vecrow_part_all_complex.q | 2 +- ...schema_evol_text_vecrow_part_all_primitive.q | 2 +- .../schema_evol_text_vecrow_table.q | 2 +- .../clientpositive/select_column_pruning.q | 4 + .../test/queries/clientpositive/semijoin_hint.q | 89 + ql/src/test/queries/clientpositive/skewjoin.q | 2 +- .../test/queries/clientpositive/smb_mapjoin9.q | 3 +- .../test/queries/clientpositive/smb_mapjoin_1.q | 1 + .../queries/clientpositive/smb_mapjoin_10.q | 2 +- .../queries/clientpositive/smb_mapjoin_11.q | 1 + .../queries/clientpositive/smb_mapjoin_12.q | 4 +- .../queries/clientpositive/smb_mapjoin_13.q | 2 +- .../queries/clientpositive/smb_mapjoin_16.q | 2 +- .../test/queries/clientpositive/smb_mapjoin_2.q | 2 +- .../test/queries/clientpositive/smb_mapjoin_3.q | 1 + .../test/queries/clientpositive/smb_mapjoin_7.q | 2 +- .../clientpositive/sort_merge_join_desc_1.q | 2 +- .../clientpositive/sort_merge_join_desc_2.q | 1 + .../clientpositive/sort_merge_join_desc_3.q | 2 +- .../clientpositive/sort_merge_join_desc_4.q | 2 +- .../clientpositive/sort_merge_join_desc_5.q | 1 + .../clientpositive/sort_merge_join_desc_6.q | 2 +- .../clientpositive/sort_merge_join_desc_7.q | 2 +- .../clientpositive/sort_merge_join_desc_8.q | 2 +- .../clientpositive/spark_explainuser_1.q | 671 + .../queries/clientpositive/subquery_multi.q | 15 + .../queries/clientpositive/subquery_scalar.q | 1 + .../queries/clientpositive/subquery_select.q | 138 +- .../temp_table_windowing_expressions.q | 2 +- .../test/queries/clientpositive/tez_smb_main.q | 13 +- .../tez_vector_dynpart_hashjoin_1.q | 1 + .../test/queries/clientpositive/tunable_ndv.q | 64 + .../clientpositive/udaf_binarysetfunctions.q | 58 + .../clientpositive/udaf_percentile_approx_23.q | 1 + .../clientpositive/udf_character_length.q | 29 + .../test/queries/clientpositive/udf_likeall.q | 57 + .../test/queries/clientpositive/udf_likeany.q | 57 + .../queries/clientpositive/udf_octet_length.q | 21 + .../clientpositive/udf_round_2_auto_stats.q | 16 + ql/src/test/queries/clientpositive/udf_trunc.q | 146 +- .../queries/clientpositive/udf_width_bucket.q | 204 + .../queries/clientpositive/unionDistinct_1.q | 4 +- .../queries/clientpositive/updateAccessTime.q | 5 + .../clientpositive/vector_binary_join_groupby.q | 22 +- .../clientpositive/vector_cast_constant.q | 4 +- .../clientpositive/vector_complex_join.q | 3 +- .../queries/clientpositive/vector_data_types.q | 16 +- .../clientpositive/vector_decimal_10_0.q | 8 +- .../clientpositive/vector_decimal_mapjoin.q | 14 +- .../clientpositive/vector_decimal_precision.q | 26 +- .../clientpositive/vector_decimal_round.q | 31 +- .../clientpositive/vector_decimal_round_2.q | 92 +- .../clientpositive/vector_groupby_cube1.q | 55 + .../vector_groupby_grouping_id1.q | 23 + .../vector_groupby_grouping_id2.q | 65 + .../vector_groupby_grouping_id3.q | 42 + .../vector_groupby_grouping_sets1.q | 43 + .../vector_groupby_grouping_sets2.q | 36 + .../vector_groupby_grouping_sets3.q | 40 + .../vector_groupby_grouping_sets4.q | 57 + .../vector_groupby_grouping_sets5.q | 39 + .../vector_groupby_grouping_sets6.q | 38 + .../vector_groupby_grouping_sets_grouping.q | 135 + .../vector_groupby_grouping_sets_limit.q | 44 + .../vector_groupby_grouping_window.q | 21 + .../clientpositive/vector_groupby_mapjoin.q | 14 + .../clientpositive/vector_groupby_reduce.q | 2 + .../clientpositive/vector_groupby_rollup1.q | 54 + .../queries/clientpositive/vector_order_null.q | 56 + .../clientpositive/vector_ptf_part_simple.q | 268 + .../clientpositive/vector_string_concat.q | 4 +- .../vector_udf_character_length.q | 31 + .../clientpositive/vector_udf_octet_length.q | 23 + .../clientpositive/vectorized_bucketmapjoin1.q | 2 +- .../queries/clientpositive/vectorized_case.q | 18 + .../vectorized_dynamic_partition_pruning.q | 3 +- .../vectorized_dynamic_semijoin_reduction.q | 2 + .../vectorized_dynamic_semijoin_reduction2.q | 4 + .../clientpositive/vectorized_parquet_types.q | 5 +- .../queries/clientpositive/vectorized_ptf.q | 46 +- ql/src/test/queries/clientpositive/windowing.q | 2 +- .../queries/clientpositive/windowing_distinct.q | 8 +- .../clientpositive/windowing_expressions.q | 2 +- .../windowing_multipartitioning.q | 6 +- .../queries/clientpositive/windowing_navfn.q | 6 +- .../queries/clientpositive/windowing_ntile.q | 4 +- .../clientpositive/windowing_order_null.q | 2 +- .../clientpositive/windowing_range_multiorder.q | 2 +- .../queries/clientpositive/windowing_rank.q | 28 +- .../clientpositive/windowing_streaming.q | 4 +- .../queries/clientpositive/windowing_udaf.q | 4 +- .../clientpositive/windowing_windowspec.q | 4 +- .../clientpositive/windowing_windowspec2.q | 2 +- .../clientpositive/zero_rows_single_insert.q | 17 + .../results/clientnegative/acid_overwrite.q.out | 2 +- .../clientnegative/alter_non_native.q.out | 2 +- .../alter_view_as_select_with_partition.q.out | 1 + .../clientnegative/alter_view_failure6.q.out | 2 +- .../results/clientnegative/bad_exec_hooks.q.out | 2 +- .../clientnegative/char_pad_convert_fail0.q.out | 4 +- .../clientnegative/char_pad_convert_fail1.q.out | 4 +- .../clientnegative/char_pad_convert_fail2.q.out | 4 +- .../clientnegative/char_pad_convert_fail3.q.out | 4 +- ...tats_partlvl_invalid_values_autogather.q.out | 69 + .../clientnegative/decimal_precision.q.out | 6 +- .../clientnegative/decimal_precision_1.q.out | 6 +- .../distinct_windowing_failure1.q.out | 4 +- .../distinct_windowing_failure2.q.out | 4 +- .../drop_default_partition_filter.q.out | 23 + .../test/results/clientnegative/external1.q.out | 2 +- .../clientnegative/input_part0_neg.q.out | 2 +- .../insert_into_with_schema.q.out | 2 +- .../insert_into_with_schema1.q.out | 2 +- .../insert_into_with_schema2.q.out | 2 +- .../results/clientnegative/msck_repair_4.q.out | 22 + .../clientnegative/nvl_mismatch_type.q.out | 4 +- .../ptf_negative_InvalidValueBoundary.q.out | 3 +- .../spark/spark_job_max_tasks.q.out | 77 + .../subquery_corr_grandparent.q.out | 2 +- .../clientnegative/subquery_in_select.q.out | 1 - .../subquery_scalar_corr_multi_rows.q.out | 5 + .../subquery_scalar_multi_columns.q.out | 4 +- .../subquery_scalar_multi_rows.q.out | 3 +- .../subquery_select_aggregate.q.out | 2 +- .../subquery_select_complex_expr.q.out | 1 - .../subquery_select_no_source.q.out | 1 + .../clientnegative/subquery_select_udf.q.out | 1 - .../clientnegative/subquery_with_or_cond.q.out | 1 - .../clientnegative/udf_likeall_wrong1.q.out | 1 + .../clientnegative/udf_likeany_wrong1.q.out | 1 + ql/src/test/results/clientnegative/union2.q.out | 2 +- .../clientnegative/wrong_column_type.q.out | 2 +- .../clientpositive/acid_table_stats.q.out | 16 +- .../clientpositive/add_part_multiple.q.out | 16 +- ...lter_numbuckets_partitioned_table2_h23.q.out | 9 + ...alter_numbuckets_partitioned_table_h23.q.out | 8 + .../alter_partition_clusterby_sortby.q.out | 1 + .../alter_partition_coltype.q.out | 2 +- .../alter_table_add_partition.q.out | 3 + .../alter_table_column_stats.q.out | 2706 ++ .../alter_table_invalidate_column_stats.q.out | 932 - .../clientpositive/alter_table_serde2.q.out | 2 + .../annotate_stats_deep_filters.q.out | 4 +- .../clientpositive/autoColumnStats_3.q.out | 1 + .../clientpositive/autoColumnStats_4.q.out | 4 +- .../clientpositive/autoColumnStats_7.q.out | 2 +- .../clientpositive/autoColumnStats_8.q.out | 4 +- .../results/clientpositive/avro_decimal.q.out | 28 +- .../clientpositive/avro_decimal_native.q.out | 28 +- .../avro_schema_evolution_native.q.out | 2 + .../results/clientpositive/ba_table_udfs.q.out | 2 +- .../beeline/drop_with_concurrency.q.out | 63 +- .../beeline/escape_comments.q.out | 428 +- .../beeline/select_dummy_source.q.out | 251 + .../clientpositive/beeline/smb_mapjoin_1.q.out | 490 + .../clientpositive/beeline/smb_mapjoin_10.q.out | 107 + .../clientpositive/beeline/smb_mapjoin_11.q.out | 2161 + .../clientpositive/beeline/smb_mapjoin_12.q.out | 430 + .../clientpositive/beeline/smb_mapjoin_13.q.out | 388 + .../clientpositive/beeline/smb_mapjoin_16.q.out | 96 + .../clientpositive/beeline/smb_mapjoin_2.q.out | 498 + .../clientpositive/beeline/smb_mapjoin_3.q.out | 494 + .../clientpositive/beeline/smb_mapjoin_7.q.out | 1268 + .../clientpositive/bucket_map_join_spark1.q.out | 8 +- .../clientpositive/bucket_map_join_spark2.q.out | 8 +- .../clientpositive/bucket_map_join_spark3.q.out | 8 +- .../results/clientpositive/bucketmapjoin5.q.out | 12 +- .../clientpositive/bucketmapjoin_negative.q.out | 2 +- .../bucketmapjoin_negative2.q.out | 2 +- .../bucketsortoptimize_insert_3.q.out | 4 +- ql/src/test/results/clientpositive/cast1.q.out | 6 +- .../clientpositive/cbo_rp_auto_join1.q.out | 4 +- .../clientpositive/cbo_rp_outer_join_ppr.q.out | 297 +- ql/src/test/results/clientpositive/char_1.q.out | 8 +- .../clientpositive/char_pad_convert.q.out | 20 +- .../columnStatsUpdateForStatsOptimizer_2.q.out | 8 +- ...names_with_leading_and_trailing_spaces.q.out | 20 + .../column_pruner_multiple_children.q.out | 189 + .../clientpositive/columnstats_infinity.q.out | 295 + .../clientpositive/columnstats_partlvl.q.out | 4 +- .../clientpositive/columnstats_partlvl_dp.q.out | 16 +- .../clientpositive/columnstats_tbllvl.q.out | 16 +- .../test/results/clientpositive/comments.q.out | 76 +- .../results/clientpositive/complex_alias.q.out | 8 +- .../clientpositive/constant_prop_3.q.out | 4 +- .../results/clientpositive/constprog2.q.out | 31 +- .../clientpositive/correlated_join_keys.q.out | 258 + .../clientpositive/correlationoptimizer13.q.out | 8 +- .../clientpositive/create_like_view.q.out | 1 + .../clientpositive/create_or_replace_view.q.out | 4 + .../create_table_like_stats.q.out | 2 + .../create_view_partitioned.q.out | 3 + .../create_with_constraints.q.out | 56 +- .../results/clientpositive/decimal_10_0.q.out | 8 +- .../clientpositive/decimal_precision.q.out | 56 +- .../results/clientpositive/decimal_udf.q.out | 12 +- .../clientpositive/default_file_format.q.out | 10 + .../results/clientpositive/deleteAnalyze.q.out | 20 +- .../clientpositive/describe_syntax.q.out | 2 + .../results/clientpositive/describe_table.q.out | 3 + .../display_colstats_tbllvl.q.out | 8 +- .../clientpositive/distinct_windowing.q.out | 4 +- .../distinct_windowing_no_cbo.q.out | 8 +- .../drop_partitions_filter4.q.out | 71 + .../results/clientpositive/druid_basic2.q.out | 376 +- .../clientpositive/druid_intervals.q.out | 138 +- .../clientpositive/druid_timeseries.q.out | 48 +- .../results/clientpositive/druid_topn.q.out | 328 +- .../clientpositive/dynamic_rdd_cache.q.out | 56 +- .../encryption_auto_purge_tables.q.out | 157 + .../encrypted/encryption_drop_partition.q.out | 37 +- .../encrypted/encryption_drop_table.q.out | 59 +- .../encryption_drop_table_in_encrypted_db.q.out | 53 + .../encrypted/encryption_move_tbl.q.out | 50 +- .../clientpositive/escape_comments.q.out | 1 + .../results/clientpositive/except_all.q.out | 16 +- .../clientpositive/exim_hidden_files.q.out | 1 + .../clientpositive/filter_cond_pushdown.q.out | 124 +- .../clientpositive/filter_join_breaktask2.q.out | 46 +- .../clientpositive/fouter_join_ppr.q.out | 594 +- .../clientpositive/fp_literal_arithmetic.q.out | 338 + .../test/results/clientpositive/groupby12.q.out | 2 +- .../test/results/clientpositive/groupby5.q.out | 2 +- .../clientpositive/groupby5_noskew.q.out | 2 +- .../results/clientpositive/groupby7_map.q.out | 4 +- .../groupby7_map_multi_single_reducer.q.out | 4 +- .../clientpositive/groupby7_map_skew.q.out | 4 +- .../clientpositive/groupby7_noskew.q.out | 4 +- .../groupby7_noskew_multi_single_reducer.q.out | 4 +- .../test/results/clientpositive/groupby8.q.out | 8 +- .../results/clientpositive/groupby8_map.q.out | 4 +- .../clientpositive/groupby8_map_skew.q.out | 4 +- .../clientpositive/groupby8_noskew.q.out | 4 +- .../test/results/clientpositive/groupby9.q.out | 28 +- .../clientpositive/groupby_cube_multi_gby.q.out | 2 +- .../clientpositive/groupby_grouping_id1.q.out | 120 +- .../clientpositive/groupby_grouping_id3.q.out | 139 + .../clientpositive/groupby_grouping_sets1.q.out | 496 +- .../clientpositive/groupby_grouping_sets2.q.out | 62 +- .../clientpositive/groupby_grouping_sets3.q.out | 41 +- .../clientpositive/groupby_grouping_sets5.q.out | 36 +- .../clientpositive/groupby_grouping_sets6.q.out | 4 +- .../groupby_grouping_sets_grouping.q.out | 470 +- .../groupby_grouping_sets_limit.q.out | 34 +- .../clientpositive/groupby_join_pushdown.q.out | 26 +- .../groupby_multi_single_reducer.q.out | 2 +- .../clientpositive/groupby_position.q.out | 34 +- .../clientpositive/groupby_sort_skew_1_23.q.out | 4 +- .../test/results/clientpositive/having2.q.out | 86 +- .../clientpositive/index_auto_unused.q.out | 38 +- .../clientpositive/index_auto_update.q.out | 4 +- .../clientpositive/infer_bucket_sort.q.out | 6 +- .../infer_bucket_sort_grouping_operators.q.out | 30 +- .../infer_bucket_sort_map_operators.q.out | 53 +- .../infer_bucket_sort_reducers_power_two.q.out | 6 +- ql/src/test/results/clientpositive/input8.q.out | 4 +- ql/src/test/results/clientpositive/input9.q.out | 4 +- .../results/clientpositive/input_part10.q.out | 24 +- .../clientpositive/inputwherefalse.q.out | 55 + .../insert_values_orig_table_use_metadata.q.out | 18 +- ql/src/test/results/clientpositive/join25.q.out | 114 +- ql/src/test/results/clientpositive/join26.q.out | 418 +- ql/src/test/results/clientpositive/join27.q.out | 112 +- ql/src/test/results/clientpositive/join30.q.out | 66 +- ql/src/test/results/clientpositive/join36.q.out | 114 +- ql/src/test/results/clientpositive/join37.q.out | 114 +- ql/src/test/results/clientpositive/join38.q.out | 108 +- ql/src/test/results/clientpositive/join39.q.out | 86 +- ql/src/test/results/clientpositive/join40.q.out | 117 +- ql/src/test/results/clientpositive/join45.q.out | 64 +- .../clientpositive/join_alt_syntax.q.out | 118 +- .../clientpositive/join_cond_pushdown_1.q.out | 100 +- .../clientpositive/join_cond_pushdown_3.q.out | 100 +- .../join_cond_pushdown_unqual1.q.out | 2 +- .../join_cond_pushdown_unqual3.q.out | 2 +- .../results/clientpositive/join_merging.q.out | 72 +- .../clientpositive/join_on_varchar.q.out | 46 +- .../results/clientpositive/join_reorder.q.out | 106 +- .../results/clientpositive/join_reorder4.q.out | 327 +- .../clientpositive/lateral_view_onview.q.out | 205 +- .../limit_pushdown_negative.q.out | 4 +- .../llap/acid_bucket_pruning.q.out | 6 +- .../clientpositive/llap/autoColumnStats_1.q.out | 1 + .../clientpositive/llap/autoColumnStats_2.q.out | 5 +- .../llap/auto_smb_mapjoin_14.q.out | 4 +- .../llap/auto_sortmerge_join_9.q.out | 4 +- .../clientpositive/llap/bucket_groupby.q.out | 426 +- .../clientpositive/llap/bucketmapjoin1.q.out | 212 +- .../clientpositive/llap/bucketmapjoin2.q.out | 156 +- .../clientpositive/llap/bucketmapjoin3.q.out | 104 +- .../clientpositive/llap/bucketmapjoin4.q.out | 104 +- .../clientpositive/llap/cbo_rp_lineage2.q.out | 58 +- .../clientpositive/llap/cbo_rp_views.q.out | 4 +- .../llap/cbo_rp_windowing_2.q.out | 54 +- .../results/clientpositive/llap/cbo_views.q.out | 2 +- .../results/clientpositive/llap/cluster.q.out | 688 +- ...names_with_leading_and_trailing_spaces.q.out | 20 + .../llap/column_table_stats.q.out | 18 +- .../llap/column_table_stats_orc.q.out | 12 +- .../llap/constprog_semijoin.q.out | 16 +- .../llap/correlationoptimizer1.q.out | 32 +- .../results/clientpositive/llap/cte_1.q.out | 37900 ++++++++--------- .../clientpositive/llap/deleteAnalyze.q.out | 16 +- .../llap/dynamic_partition_pruning.q.out | 39 +- .../llap/dynamic_partition_pruning_2.q.out | 72 +- .../llap/dynamic_semijoin_reduction.q.out | 1159 +- .../llap/dynamic_semijoin_reduction_2.q.out | 8 +- .../llap/dynamic_semijoin_reduction_3.q.out | 266 +- .../llap/dynamic_semijoin_user_level.q.out | 1486 + .../llap/dynpart_sort_opt_vectorization.q.out | 50 +- .../llap/dynpart_sort_optimization.q.out | 4 +- .../llap/dynpart_sort_optimization2.q.out | 4 +- .../clientpositive/llap/except_distinct.q.out | 2 +- .../clientpositive/llap/explainuser_1.q.out | 1356 +- .../clientpositive/llap/explainuser_2.q.out | 2302 +- .../clientpositive/llap/explainuser_4.q.out | 6 +- .../llap/filter_join_breaktask2.q.out | 46 +- .../llap/groupby_grouping_id2.q.out | 9 + .../llap/hybridgrace_hashjoin_2.q.out | 4 +- .../clientpositive/llap/intersect_all.q.out | 1470 +- .../llap/intersect_distinct.q.out | 924 +- .../clientpositive/llap/is_distinct_from.q.out | 335 + .../clientpositive/llap/jdbc_handler.q.out | 52 +- .../clientpositive/llap/join_filters.q.out | 8 +- .../llap/join_is_not_distinct_from.q.out | 1673 + .../clientpositive/llap/join_nulls.q.out | 2 +- .../clientpositive/llap/lateral_view.q.out | 12 +- .../clientpositive/llap/limit_pushdown.q.out | 4 +- .../clientpositive/llap/limit_pushdown3.q.out | 4 +- .../results/clientpositive/llap/lineage2.q.out | 58 +- .../results/clientpositive/llap/lineage3.q.out | 4 +- .../clientpositive/llap/llap_stats.q.out | 4 +- .../llap/llap_vector_nohybridgrace.q.out | 356 + .../clientpositive/llap/mapjoin_decimal.q.out | 32 +- .../results/clientpositive/llap/mergejoin.q.out | 470 +- .../llap/metadata_only_queries.q.out | 12 +- .../metadata_only_queries_with_filters.q.out | 16 +- .../clientpositive/llap/multiMapJoin1.q.out | 4 +- .../clientpositive/llap/multi_column_in.q.out | 2 +- .../llap/multi_count_distinct_null.q.out | 24 +- .../llap/multi_insert_lateral_view.q.out | 316 +- .../llap/offset_limit_ppd_optimizer.q.out | 4 +- .../clientpositive/llap/orc_analyze.q.out | 32 +- .../clientpositive/llap/orc_create.q.out | 4 + .../clientpositive/llap/orc_llap_counters.q.out | 20 +- .../llap/orc_llap_counters1.q.out | 20 +- .../clientpositive/llap/orc_merge10.q.out | 4 +- .../clientpositive/llap/orc_merge11.q.out | 110 +- .../clientpositive/llap/orc_merge12.q.out | 4 +- .../clientpositive/llap/orc_ppd_basic.q.out | 20 +- .../clientpositive/llap/orc_ppd_decimal.q.out | 4 +- .../llap/orc_ppd_schema_evol_3a.q.out | 20 +- .../llap/orc_predicate_pushdown.q.out | 14 +- .../clientpositive/llap/parallel_colstats.q.out | 1516 + .../llap/parquet_predicate_pushdown.q.out | 14 +- .../clientpositive/llap/parquet_types.q.out | 2 +- .../llap/partition_multilevels.q.out | 244 +- .../test/results/clientpositive/llap/ptf.q.out | 12 +- .../llap/reduce_deduplicate_extended.q.out | 78 +- .../llap/schema_evol_orc_acid_part.q.out | 91 +- .../llap/schema_evol_orc_acid_table.q.out | 11 + .../llap/schema_evol_orc_acidvec_part.q.out | 700 +- .../llap/schema_evol_orc_acidvec_table.q.out | 686 + .../llap/schema_evol_orc_nonvec_part.q.out | 450 +- ...chema_evol_orc_nonvec_part_all_complex.q.out | 150 +- ...ema_evol_orc_nonvec_part_all_primitive.q.out | 250 +- .../llap/schema_evol_orc_nonvec_table.q.out | 250 +- .../clientpositive/llap/schema_evol_stats.q.out | 2 + .../llap/schema_evol_text_nonvec_part.q.out | 450 +- ...hema_evol_text_nonvec_part_all_complex.q.out | 150 +- ...ma_evol_text_nonvec_part_all_primitive.q.out | 250 +- .../llap/schema_evol_text_nonvec_table.q.out | 250 +- .../clientpositive/llap/semijoin_hint.q.out | 2646 ++ .../results/clientpositive/llap/skewjoin.q.out | 98 +- .../clientpositive/llap/skiphf_aggr.q.out | 4 +- .../clientpositive/llap/smb_mapjoin_14.q.out | 207 +- .../clientpositive/llap/smb_mapjoin_15.q.out | 276 +- .../clientpositive/llap/smb_mapjoin_17.q.out | 98 +- .../clientpositive/llap/smb_mapjoin_4.q.out | 889 +- .../clientpositive/llap/smb_mapjoin_5.q.out | 889 +- .../clientpositive/llap/smb_mapjoin_6.q.out | 274 +- .../results/clientpositive/llap/stats11.q.out | 104 +- .../clientpositive/llap/stats_noscan_1.q.out | 1 + .../clientpositive/llap/subquery_exists.q.out | 41 +- .../clientpositive/llap/subquery_in.q.out | 630 +- .../clientpositive/llap/subquery_multi.q.out | 1490 +- .../clientpositive/llap/subquery_notin.q.out | 692 +- .../clientpositive/llap/subquery_scalar.q.out | 2780 +- .../clientpositive/llap/subquery_select.q.out | 5387 ++- .../llap/table_access_keys_stats.q.out | 4 +- .../llap/tez_dynpart_hashjoin_1.q.out | 2 +- .../clientpositive/llap/tez_join_hash.q.out | 10 +- .../clientpositive/llap/tez_smb_main.q.out | 426 + .../clientpositive/llap/tez_union2.q.out | 924 +- .../llap/tez_union_multiinsert.q.out | 182 +- .../llap/tez_vector_dynpart_hashjoin_1.q.out | 4 +- .../llap/tez_vector_dynpart_hashjoin_2.q.out | 8 +- .../clientpositive/llap/unionDistinct_1.q.out | 4186 +- .../clientpositive/llap/union_fast_stats.q.out | 12 +- .../llap/vector_adaptor_usage_mode.q.out | 2 +- .../llap/vector_aggregate_without_gby.q.out | 12 +- .../llap/vector_auto_smb_mapjoin_14.q.out | 23 +- .../llap/vector_between_columns.q.out | 26 +- .../clientpositive/llap/vector_between_in.q.out | 102 +- .../llap/vector_binary_join_groupby.q.out | 116 +- .../clientpositive/llap/vector_bround.q.out | 4 +- .../clientpositive/llap/vector_bucket.q.out | 25 +- .../llap/vector_cast_constant.q.out | 8 +- .../clientpositive/llap/vector_char_2.q.out | 20 +- .../llap/vector_char_mapjoin1.q.out | 33 +- .../llap/vector_char_simple.q.out | 4 +- .../clientpositive/llap/vector_coalesce.q.out | 20 +- .../clientpositive/llap/vector_coalesce_2.q.out | 10 +- .../llap/vector_complex_all.q.out | 6 +- .../clientpositive/llap/vector_count.q.out | 16 +- .../llap/vector_count_distinct.q.out | 9 +- .../clientpositive/llap/vector_data_types.q.out | 36 +- .../llap/vector_decimal_10_0.q.out | 12 +- .../llap/vector_decimal_aggregate.q.out | 14 +- .../llap/vector_decimal_expressions.q.out | 4 +- .../llap/vector_decimal_mapjoin.q.out | 30 +- .../llap/vector_decimal_precision.q.out | 52 +- .../llap/vector_decimal_round.q.out | 123 +- .../llap/vector_decimal_round_2.q.out | 210 +- .../llap/vector_decimal_udf.q.out | 44 +- .../clientpositive/llap/vector_distinct_2.q.out | 2 +- .../llap/vector_empty_where.q.out | 36 +- .../clientpositive/llap/vector_groupby4.q.out | 11 +- .../clientpositive/llap/vector_groupby6.q.out | 11 +- .../clientpositive/llap/vector_groupby_3.q.out | 8 +- .../llap/vector_groupby_cube1.q.out | 773 + .../llap/vector_groupby_grouping_id1.q.out | 179 + .../llap/vector_groupby_grouping_id2.q.out | 359 + .../llap/vector_groupby_grouping_id3.q.out | 370 + .../llap/vector_groupby_grouping_sets1.q.out | 668 + .../llap/vector_groupby_grouping_sets2.q.out | 469 + .../llap/vector_groupby_grouping_sets3.q.out | 314 + .../llap/vector_groupby_grouping_sets4.q.out | 554 + .../llap/vector_groupby_grouping_sets5.q.out | 371 + .../llap/vector_groupby_grouping_sets6.q.out | 192 + .../vector_groupby_grouping_sets_grouping.q.out | 1224 + .../vector_groupby_grouping_sets_limit.q.out | 650 + .../llap/vector_groupby_grouping_window.q.out | 157 + .../llap/vector_groupby_mapjoin.q.out | 142 +- .../llap/vector_groupby_reduce.q.out | 79 +- .../llap/vector_groupby_rollup1.q.out | 610 + .../llap/vector_grouping_sets.q.out | 77 +- .../clientpositive/llap/vector_if_expr.q.out | 9 +- .../llap/vector_include_no_sel.q.out | 8 +- .../clientpositive/llap/vector_inner_join.q.out | 18 +- .../clientpositive/llap/vector_interval_1.q.out | 72 +- .../clientpositive/llap/vector_interval_2.q.out | 104 +- .../llap/vector_interval_arithmetic.q.out | 58 +- .../llap/vector_interval_mapjoin.q.out | 10 +- .../clientpositive/llap/vector_join30.q.out | 251 +- .../llap/vector_left_outer_join2.q.out | 8 +- .../llap/vector_leftsemi_mapjoin.q.out | 838 +- .../llap/vector_mapjoin_reduce.q.out | 167 +- .../llap/vector_non_string_partition.q.out | 144 +- .../llap/vector_nullsafe_join.q.out | 36 +- .../llap/vector_number_compare_projection.q.out | 18 +- .../clientpositive/llap/vector_order_null.q.out | 1360 + .../clientpositive/llap/vector_orderby_5.q.out | 15 +- .../llap/vector_outer_join0.q.out | 4 +- .../llap/vector_outer_join1.q.out | 17 +- .../llap/vector_outer_join2.q.out | 13 +- .../llap/vector_partition_diff_num_cols.q.out | 35 +- .../llap/vector_partitioned_date_time.q.out | 82 +- .../llap/vector_ptf_part_simple.q.out | 3032 ++ .../clientpositive/llap/vector_reduce1.q.out | 9 +- .../clientpositive/llap/vector_reduce2.q.out | 9 +- .../clientpositive/llap/vector_reduce3.q.out | 9 +- .../llap/vector_reduce_groupby_decimal.q.out | 6 +- .../llap/vector_string_concat.q.out | 14 +- .../llap/vector_tablesample_rows.q.out | 7 +- .../llap/vector_udf_character_length.q.out | 287 + .../llap/vector_udf_octet_length.q.out | 222 + .../llap/vector_varchar_mapjoin1.q.out | 6 +- .../llap/vector_varchar_simple.q.out | 4 +- .../llap/vector_when_case_null.q.out | 2 +- .../clientpositive/llap/vectorization_0.q.out | 100 +- .../clientpositive/llap/vectorization_13.q.out | 12 +- .../clientpositive/llap/vectorization_15.q.out | 10 +- .../clientpositive/llap/vectorization_17.q.out | 2 +- .../clientpositive/llap/vectorization_7.q.out | 8 +- .../clientpositive/llap/vectorization_8.q.out | 8 +- .../llap/vectorization_div0.q.out | 414 +- .../llap/vectorization_limit.q.out | 469 +- .../llap/vectorization_offset_limit.q.out | 4 +- .../llap/vectorization_short_regress.q.out | 132 +- .../llap/vectorized_bucketmapjoin1.q.out | 29 +- .../clientpositive/llap/vectorized_case.q.out | 254 + .../llap/vectorized_date_funcs.q.out | 14 +- .../llap/vectorized_distinct_gby.q.out | 2 +- .../vectorized_dynamic_partition_pruning.q.out | 518 +- .../vectorized_dynamic_semijoin_reduction.q.out | 246 +- ...vectorized_dynamic_semijoin_reduction2.q.out | 32 +- .../clientpositive/llap/vectorized_join46.q.out | 58 +- .../llap/vectorized_mapjoin.q.out | 2 +- .../llap/vectorized_mapjoin2.q.out | 9 +- .../llap/vectorized_parquet.q.out | 168 +- .../llap/vectorized_parquet_types.q.out | 189 +- .../clientpositive/llap/vectorized_ptf.q.out | 2552 +- .../llap/vectorized_shufflejoin.q.out | 4 +- .../llap/vectorized_timestamp.q.out | 22 +- .../llap/vectorized_timestamp_funcs.q.out | 43 +- .../results/clientpositive/llap/windowing.q.out | 54 +- .../clientpositive/llap/windowing_gby.q.out | 42 +- .../llap/windowing_windowspec2.q.out | 4 +- .../test/results/clientpositive/llap_text.q.out | 4 +- .../clientpositive/louter_join_ppr.q.out | 331 +- .../test/results/clientpositive/mapjoin1.q.out | 340 +- .../clientpositive/mapjoin_distinct.q.out | 256 +- .../results/clientpositive/mapjoin_hook.q.out | 4 +- .../test/results/clientpositive/mergejoin.q.out | 23 +- .../results/clientpositive/mergejoins.q.out | 2 +- .../clientpositive/metadata_only_queries.q.out | 12 +- .../metadata_only_queries_with_filters.q.out | 16 +- .../results/clientpositive/msck_repair_0.q.out | 8 + .../clientpositive/multi_insert_gby3.q.out | 6 +- .../clientpositive/multi_insert_mixed.q.out | 6 +- .../clientpositive/multigroupby_singlemr.q.out | 4 +- .../clientpositive/named_column_join.q.out | 482 + .../clientpositive/nested_column_pruning.q.out | 8 +- .../results/clientpositive/null_column.q.out | 4 +- .../optimize_filter_literal.q.out | 147 + .../results/clientpositive/orc_file_dump.q.out | 120 +- .../results/clientpositive/orc_merge10.q.out | 4 +- .../results/clientpositive/orc_merge11.q.out | 110 +- .../results/clientpositive/orc_merge12.q.out | 4 +- .../results/clientpositive/outer_join_ppr.q.out | 289 +- .../outer_reference_windowed.q.out | 847 + .../clientpositive/parallel_colstats.q.out | 1529 + .../clientpositive/parquet_decimal.q.out | 24 +- .../parquet_mixed_partition_formats.q.out | 1 + .../clientpositive/parquet_partitioned.q.out | 1 + .../clientpositive/parquet_ppd_multifiles.q.out | 12 +- .../results/clientpositive/parquet_serde.q.out | 1 + ..._non_dictionary_encoding_vectorization.q.out | 4 +- .../parquet_types_vectorization.q.out | 4 +- .../partitions_filter_default.q.out | 67 + ql/src/test/results/clientpositive/pcs.q.out | 150 +- .../results/clientpositive/perf/query1.q.out | 260 +- .../results/clientpositive/perf/query12.q.out | 2 +- .../results/clientpositive/perf/query13.q.out | 186 +- .../results/clientpositive/perf/query14.q.out | 2004 +- .../results/clientpositive/perf/query15.q.out | 120 +- .../results/clientpositive/perf/query16.q.out | 60 +- .../results/clientpositive/perf/query17.q.out | 214 +- .../results/clientpositive/perf/query18.q.out | 2 +- .../results/clientpositive/perf/query19.q.out | 190 +- .../results/clientpositive/perf/query20.q.out | 70 +- .../results/clientpositive/perf/query21.q.out | 2 +- .../results/clientpositive/perf/query22.q.out | 98 +- .../results/clientpositive/perf/query23.q.out | 832 +- .../results/clientpositive/perf/query25.q.out | 212 +- .../results/clientpositive/perf/query26.q.out | 126 +- .../results/clientpositive/perf/query29.q.out | 212 +- .../results/clientpositive/perf/query3.q.out | 70 +- .../results/clientpositive/perf/query30.q.out | 353 +- .../results/clientpositive/perf/query31.q.out | 606 +- .../results/clientpositive/perf/query32.q.out | 156 +- .../results/clientpositive/perf/query36.q.out | 4 +- .../results/clientpositive/perf/query37.q.out | 2 +- .../results/clientpositive/perf/query38.q.out | 210 +- .../results/clientpositive/perf/query39.q.out | 196 +- .../results/clientpositive/perf/query40.q.out | 2 +- .../results/clientpositive/perf/query42.q.out | 70 +- .../results/clientpositive/perf/query46.q.out | 126 +- .../results/clientpositive/perf/query48.q.out | 158 +- .../results/clientpositive/perf/query5.q.out | 302 +- .../results/clientpositive/perf/query51.q.out | 84 +- .../results/clientpositive/perf/query52.q.out | 70 +- .../results/clientpositive/perf/query54.q.out | 244 +- .../results/clientpositive/perf/query55.q.out | 70 +- .../results/clientpositive/perf/query58.q.out | 472 +- .../results/clientpositive/perf/query6.q.out | 351 +- .../results/clientpositive/perf/query64.q.out | 1218 +- .../results/clientpositive/perf/query65.q.out | 202 +- .../results/clientpositive/perf/query66.q.out | 2 +- .../results/clientpositive/perf/query67.q.out | 2 +- .../results/clientpositive/perf/query68.q.out | 126 +- .../results/clientpositive/perf/query69.q.out | 204 +- .../results/clientpositive/perf/query7.q.out | 126 +- .../results/clientpositive/perf/query70.q.out | 154 +- .../results/clientpositive/perf/query71.q.out | 202 +- .../results/clientpositive/perf/query72.q.out | 334 +- .../results/clientpositive/perf/query75.q.out | 14 +- .../results/clientpositive/perf/query79.q.out | 98 +- .../results/clientpositive/perf/query8.q.out | 222 +- .../results/clientpositive/perf/query80.q.out | 6 +- .../results/clientpositive/perf/query81.q.out | 355 +- .../results/clientpositive/perf/query82.q.out | 2 +- .../results/clientpositive/perf/query83.q.out | 462 +- .../results/clientpositive/perf/query85.q.out | 266 +- .../results/clientpositive/perf/query86.q.out | 4 +- .../results/clientpositive/perf/query87.q.out | 210 +- .../results/clientpositive/perf/query88.q.out | 224 +- .../results/clientpositive/perf/query89.q.out | 98 +- .../results/clientpositive/perf/query9.q.out | 829 + .../results/clientpositive/perf/query91.q.out | 178 +- .../results/clientpositive/perf/query92.q.out | 42 +- .../results/clientpositive/perf/query97.q.out | 42 +- .../results/clientpositive/perf/query98.q.out | 70 +- .../clientpositive/position_alias_test_1.q.out | 113 +- .../clientpositive/ppd_constant_expr.q.out | 8 +- .../test/results/clientpositive/ppd_gby.q.out | 48 +- .../test/results/clientpositive/ppd_gby2.q.out | 48 +- .../test/results/clientpositive/ppd_join2.q.out | 108 +- .../test/results/clientpositive/ppd_join3.q.out | 170 +- .../clientpositive/ppd_outer_join1.q.out | 74 +- .../results/clientpositive/ppd_windowing1.q.out | 36 +- .../clientpositive/primitive_types.q.out | 10 +- .../results/clientpositive/ptfgroupbyjoin.q.out | 40 +- .../results/clientpositive/quotedid_stats.q.out | 86 + .../reduce_deduplicate_extended2.q.out | 167 +- .../clientpositive/remove_exprs_stats.q.out | 6 +- .../rename_partition_location.q.out | 23 + .../clientpositive/router_join_ppr.q.out | 319 +- .../test/results/clientpositive/row__id.q.out | 34 +- .../clientpositive/select_column_pruning.q.out | 141 + .../test/results/clientpositive/semijoin5.q.out | 2 +- .../results/clientpositive/show_functions.q.out | 19 + .../test/results/clientpositive/skewjoin.q.out | 198 +- .../results/clientpositive/smb_mapjoin_20.q.out | 6 +- .../spark/add_part_multiple.q.out | 16 +- .../spark/auto_smb_mapjoin_14.q.out | 4 +- .../spark/auto_sortmerge_join_9.q.out | 4 +- .../spark/avro_decimal_native.q.out | 28 +- .../spark/bucket_map_join_spark1.q.out | 8 +- .../spark/bucket_map_join_spark2.q.out | 8 +- .../spark/bucket_map_join_spark3.q.out | 8 +- .../clientpositive/spark/bucketmapjoin1.q.out | 664 +- .../clientpositive/spark/bucketmapjoin2.q.out | 624 +- .../clientpositive/spark/bucketmapjoin3.q.out | 376 +- .../clientpositive/spark/bucketmapjoin4.q.out | 326 +- .../clientpositive/spark/bucketmapjoin5.q.out | 12 +- .../spark/bucketmapjoin_negative.q.out | 2 +- .../spark/bucketmapjoin_negative2.q.out | 2 +- .../spark/constprog_semijoin.q.out | 16 +- .../spark/dynamic_rdd_cache.q.out | 52 +- .../spark/filter_join_breaktask2.q.out | 46 +- .../results/clientpositive/spark/groupby5.q.out | 2 +- .../clientpositive/spark/groupby5_noskew.q.out | 2 +- .../clientpositive/spark/groupby7_map.q.out | 4 +- .../groupby7_map_multi_single_reducer.q.out | 4 +- .../spark/groupby7_map_skew.q.out | 4 +- .../clientpositive/spark/groupby7_noskew.q.out | 4 +- .../groupby7_noskew_multi_single_reducer.q.out | 4 +- .../results/clientpositive/spark/groupby8.q.out | 8 +- .../clientpositive/spark/groupby8_map.q.out | 4 +- .../spark/groupby8_map_skew.q.out | 4 +- .../clientpositive/spark/groupby8_noskew.q.out | 4 +- .../results/clientpositive/spark/groupby9.q.out | 28 +- .../spark/groupby_grouping_id2.q.out | 9 + .../clientpositive/spark/groupby_position.q.out | 30 +- .../spark/infer_bucket_sort_map_operators.q.out | 54 +- .../results/clientpositive/spark/join25.q.out | 56 +- .../results/clientpositive/spark/join26.q.out | 192 +- .../results/clientpositive/spark/join27.q.out | 54 +- .../results/clientpositive/spark/join30.q.out | 56 +- .../results/clientpositive/spark/join36.q.out | 64 +- .../results/clientpositive/spark/join37.q.out | 56 +- .../results/clientpositive/spark/join38.q.out | 106 +- .../results/clientpositive/spark/join39.q.out | 32 +- .../clientpositive/spark/join_alt_syntax.q.out | 98 +- .../spark/join_cond_pushdown_1.q.out | 86 +- .../spark/join_cond_pushdown_3.q.out | 86 +- .../spark/join_cond_pushdown_unqual1.q.out | 2 +- .../spark/join_cond_pushdown_unqual3.q.out | 2 +- .../clientpositive/spark/join_merging.q.out | 80 +- .../clientpositive/spark/join_reorder.q.out | 106 +- .../clientpositive/spark/join_reorder4.q.out | 339 +- .../clientpositive/spark/limit_pushdown.q.out | 4 +- .../clientpositive/spark/louter_join_ppr.q.out | 331 +- .../results/clientpositive/spark/mapjoin1.q.out | 284 +- .../clientpositive/spark/mapjoin_decimal.q.out | 32 +- .../clientpositive/spark/mapjoin_distinct.q.out | 192 +- .../clientpositive/spark/mergejoins.q.out | 2 +- .../spark/metadata_only_queries.q.out | 12 +- .../metadata_only_queries_with_filters.q.out | 16 +- .../spark/multi_insert_gby3.q.out | 4 +- .../spark/multi_insert_lateral_view.q.out | 316 +- .../spark/multi_insert_mixed.q.out | 4 +- .../spark/multigroupby_singlemr.q.out | 4 +- .../clientpositive/spark/outer_join_ppr.q.out | 289 +- .../clientpositive/spark/ppd_join2.q.out | 160 +- .../clientpositive/spark/ppd_join3.q.out | 110 +- .../clientpositive/spark/ppd_outer_join1.q.out | 74 +- .../test/results/clientpositive/spark/ptf.q.out | 12 +- .../clientpositive/spark/router_join_ppr.q.out | 319 +- .../results/clientpositive/spark/skewjoin.q.out | 198 +- .../clientpositive/spark/smb_mapjoin_14.q.out | 822 +- .../clientpositive/spark/smb_mapjoin_15.q.out | 566 +- .../clientpositive/spark/smb_mapjoin_17.q.out | 168 +- .../clientpositive/spark/smb_mapjoin_20.q.out | 6 +- .../clientpositive/spark/smb_mapjoin_4.q.out | 1093 +- .../clientpositive/spark/smb_mapjoin_5.q.out | 1093 +- .../clientpositive/spark/smb_mapjoin_6.q.out | 360 +- .../spark/spark_explainuser_1.q.out | 5921 +++ .../results/clientpositive/spark/stats10.q.out | 1 + .../results/clientpositive/spark/stats12.q.out | 1 + .../results/clientpositive/spark/stats13.q.out | 2 + .../results/clientpositive/spark/stats14.q.out | 2 + .../results/clientpositive/spark/stats15.q.out | 2 + .../results/clientpositive/spark/stats2.q.out | 2 + .../results/clientpositive/spark/stats3.q.out | 1 + .../results/clientpositive/spark/stats6.q.out | 1 + .../results/clientpositive/spark/stats7.q.out | 1 + .../results/clientpositive/spark/stats8.q.out | 2 + .../clientpositive/spark/stats_noscan_1.q.out | 1 + .../clientpositive/spark/subquery_exists.q.out | 37 +- .../clientpositive/spark/subquery_in.q.out | 623 +- .../spark/table_access_keys_stats.q.out | 4 +- .../results/clientpositive/spark/union17.q.out | 40 +- .../results/clientpositive/spark/union19.q.out | 20 +- .../clientpositive/spark/union_remove_15.q.out | 1 + .../clientpositive/spark/union_remove_16.q.out | 1 + .../clientpositive/spark/union_remove_17.q.out | 1 + .../clientpositive/spark/union_remove_18.q.out | 1 + .../clientpositive/spark/union_remove_19.q.out | 4 +- .../spark/vector_between_in.q.out | 122 +- .../spark/vector_cast_constant.q.out | 8 +- .../spark/vector_count_distinct.q.out | 14 +- .../spark/vector_data_types.q.out | 36 +- .../spark/vector_decimal_aggregate.q.out | 19 +- .../spark/vector_decimal_mapjoin.q.out | 28 +- .../spark/vector_distinct_2.q.out | 7 +- .../clientpositive/spark/vector_groupby_3.q.out | 13 +- .../spark/vector_mapjoin_reduce.q.out | 157 +- .../clientpositive/spark/vector_orderby_5.q.out | 20 +- .../spark/vector_outer_join1.q.out | 49 +- .../spark/vector_outer_join2.q.out | 25 +- .../spark/vector_string_concat.q.out | 16 +- .../clientpositive/spark/vectorization_0.q.out | 99 +- .../clientpositive/spark/vectorization_13.q.out | 12 +- .../clientpositive/spark/vectorization_15.q.out | 10 +- .../clientpositive/spark/vectorization_17.q.out | 2 +- .../spark/vectorization_div0.q.out | 8 +- .../spark/vectorization_short_regress.q.out | 132 +- .../clientpositive/spark/vectorized_case.q.out | 250 + .../clientpositive/spark/vectorized_ptf.q.out | 2571 +- .../spark/vectorized_shufflejoin.q.out | 18 +- .../spark/vectorized_timestamp_funcs.q.out | 43 +- .../clientpositive/spark/windowing.q.out | 54 +- .../test/results/clientpositive/stats10.q.out | 1 + .../test/results/clientpositive/stats12.q.out | 1 + .../test/results/clientpositive/stats13.q.out | 2 + .../test/results/clientpositive/stats14.q.out | 2 + .../test/results/clientpositive/stats15.q.out | 2 + ql/src/test/results/clientpositive/stats2.q.out | 2 + ql/src/test/results/clientpositive/stats3.q.out | 1 + ql/src/test/results/clientpositive/stats4.q.out | 2 + ql/src/test/results/clientpositive/stats6.q.out | 1 + ql/src/test/results/clientpositive/stats7.q.out | 1 + ql/src/test/results/clientpositive/stats8.q.out | 2 + .../results/clientpositive/stats_noscan_1.q.out | 1 + .../test/results/clientpositive/structin.q.out | 1 + .../subq_where_serialization.q.out | 112 +- .../clientpositive/subquery_exists.q.out | 43 +- .../clientpositive/subquery_in_having.q.out | 81 +- .../clientpositive/subquery_notexists.q.out | 20 +- .../subquery_notexists_having.q.out | 24 +- .../clientpositive/subquery_notin_having.q.out | 130 +- .../subquery_unqualcolumnrefs.q.out | 76 +- .../temp_table_display_colstats_tbllvl.q.out | 11 +- .../temp_table_windowing_expressions.q.out | 4 +- .../clientpositive/tez/explainanalyze_2.q.out | 230 +- .../clientpositive/tez/explainanalyze_3.q.out | 127 +- .../clientpositive/tez/explainuser_3.q.out | 150 +- .../clientpositive/tez/orc_merge12.q.out | 4 +- .../clientpositive/tez/vector_aggregate_9.q.out | 4 - .../tez/vector_auto_smb_mapjoin_14.q.out | 15 +- .../tez/vector_between_columns.q.out | 18 +- .../clientpositive/tez/vector_between_in.q.out | 102 +- .../tez/vector_binary_join_groupby.q.out | 13 +- .../tez/vector_cast_constant.q.out | 4 - .../clientpositive/tez/vector_char_2.q.out | 12 +- .../tez/vector_char_mapjoin1.q.out | 33 +- .../clientpositive/tez/vector_char_simple.q.out | 4 +- .../clientpositive/tez/vector_coalesce.q.out | 20 +- .../clientpositive/tez/vector_coalesce_2.q.out | 2 +- .../tez/vector_join_part_col_char.q.out | 18 +- .../tez/vector_non_string_partition.q.out | 8 +- .../clientpositive/tez/vectorization_div0.q.out | 8 +- .../tez/vectorization_limit.q.out | 69 +- .../results/clientpositive/tez_join_hash.q.out | 5 + .../results/clientpositive/tunable_ndv.q.out | 220 + .../udaf_binarysetfunctions.q.out | 464 + .../test/results/clientpositive/udaf_corr.q.out | 13 +- .../clientpositive/udaf_covar_samp.q.out | 16 +- ql/src/test/results/clientpositive/udf1.q.out | 32 +- ql/src/test/results/clientpositive/udf3.q.out | 20 +- .../results/clientpositive/udf_between.q.out | 4 +- .../clientpositive/udf_character_length.q.out | 269 + .../results/clientpositive/udf_length.q.out | 2 +- .../results/clientpositive/udf_likeall.q.out | 187 + .../results/clientpositive/udf_likeany.q.out | 187 + .../clientpositive/udf_octet_length.q.out | 221 + .../clientpositive/udf_round_2_auto_stats.q.out | 55 + .../test/results/clientpositive/udf_trunc.q.out | 371 +- .../clientpositive/udf_width_bucket.q.out | 680 + .../clientpositive/unicode_comments.q.out | 1 + .../test/results/clientpositive/union17.q.out | 40 +- .../test/results/clientpositive/union19.q.out | 20 +- .../clientpositive/union_remove_15.q.out | 1 + .../clientpositive/union_remove_16.q.out | 1 + .../clientpositive/union_remove_17.q.out | 1 + .../clientpositive/union_remove_18.q.out | 1 + .../clientpositive/union_remove_19.q.out | 4 +- .../clientpositive/updateAccessTime.q.out | 16 + .../test/results/clientpositive/varchar_1.q.out | 4 +- .../clientpositive/vector_between_columns.q.out | 8 +- .../vector_binary_join_groupby.q.out | 131 +- .../results/clientpositive/vector_bucket.q.out | 21 +- .../clientpositive/vector_cast_constant.q.out | 25 +- .../results/clientpositive/vector_char_2.q.out | 50 +- .../clientpositive/vector_char_mapjoin1.q.out | 12 +- .../clientpositive/vector_char_simple.q.out | 4 +- .../clientpositive/vector_coalesce.q.out | 20 +- .../clientpositive/vector_coalesce_2.q.out | 8 +- .../results/clientpositive/vector_count.q.out | 16 +- .../clientpositive/vector_data_types.q.out | 36 +- .../clientpositive/vector_decimal_10_0.q.out | 12 +- .../vector_decimal_aggregate.q.out | 16 +- .../vector_decimal_expressions.q.out | 4 +- .../clientpositive/vector_decimal_mapjoin.q.out | 28 +- .../vector_decimal_precision.q.out | 52 +- .../clientpositive/vector_decimal_round.q.out | 111 +- .../clientpositive/vector_decimal_round_2.q.out | 190 +- .../clientpositive/vector_distinct_2.q.out | 4 +- .../clientpositive/vector_empty_where.q.out | 16 +- .../clientpositive/vector_groupby4.q.out | 21 +- .../clientpositive/vector_groupby6.q.out | 21 +- .../clientpositive/vector_groupby_3.q.out | 10 +- .../clientpositive/vector_groupby_mapjoin.q.out | 165 +- .../clientpositive/vector_groupby_reduce.q.out | 128 +- .../clientpositive/vector_grouping_sets.q.out | 51 +- .../results/clientpositive/vector_if_expr.q.out | 4 +- .../clientpositive/vector_include_no_sel.q.out | 4 +- .../clientpositive/vector_interval_1.q.out | 32 +- .../vector_interval_arithmetic.q.out | 28 +- .../vector_interval_mapjoin.q.out | 6 +- .../clientpositive/vector_mapjoin_reduce.q.out | 112 +- .../vector_mr_diff_schema_alias.q.out | 18 +- .../vector_non_constant_in_expr.q.out | 4 +- .../vector_non_string_partition.q.out | 8 +- .../clientpositive/vector_order_null.q.out | 1096 + .../clientpositive/vector_orderby_5.q.out | 27 +- .../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 | 6 +- .../clientpositive/vector_outer_join6.q.out | 4 +- .../results/clientpositive/vector_reduce1.q.out | 4 +- .../results/clientpositive/vector_reduce2.q.out | 4 +- .../results/clientpositive/vector_reduce3.q.out | 4 +- .../vector_reduce_groupby_decimal.q.out | 21 +- .../clientpositive/vector_string_concat.q.out | 29 +- .../clientpositive/vector_string_decimal.q.out | 23 +- .../vector_tablesample_rows.q.out | 17 +- .../vector_udf_character_length.q.out | 315 + .../vector_udf_octet_length.q.out | 254 + .../clientpositive/vector_varchar_simple.q.out | 4 +- .../clientpositive/vector_when_case_null.q.out | 4 +- .../clientpositive/vectorization_13.q.out | 46 +- .../clientpositive/vectorization_14.q.out | 9 +- .../clientpositive/vectorization_15.q.out | 19 +- .../clientpositive/vectorization_7.q.out | 8 +- .../clientpositive/vectorization_8.q.out | 8 +- .../clientpositive/vectorization_div0.q.out | 8 +- .../clientpositive/vectorization_limit.q.out | 79 +- .../vectorization_offset_limit.q.out | 4 +- .../clientpositive/vectorized_case.q.out | 222 + .../clientpositive/vectorized_date_funcs.q.out | 21 +- .../clientpositive/vectorized_mapjoin2.q.out | 4 +- .../vectorized_parquet_types.q.out | 23 +- .../clientpositive/vectorized_shufflejoin.q.out | 23 +- .../clientpositive/vectorized_timestamp.q.out | 4 +- .../vectorized_timestamp_funcs.q.out | 20 +- .../clientpositive/windowing_distinct.q.out | 16 +- .../clientpositive/windowing_expressions.q.out | 4 +- .../results/clientpositive/windowing_gby2.q.out | 34 +- .../windowing_multipartitioning.q.out | 12 +- .../clientpositive/windowing_navfn.q.out | 12 +- .../clientpositive/windowing_ntile.q.out | 8 +- .../clientpositive/windowing_order_null.q.out | 4 +- .../windowing_range_multiorder.q.out | 4 +- .../results/clientpositive/windowing_rank.q.out | 56 +- .../clientpositive/windowing_streaming.q.out | 4 +- .../results/clientpositive/windowing_udaf.q.out | 4 +- .../clientpositive/windowing_windowspec.q.out | 112 +- .../zero_rows_single_insert.q.out | 113 + serde/pom.xml | 2 +- .../hive/serde2/ColumnProjectionUtils.java | 6 +- .../apache/hadoop/hive/serde2/SerDeUtils.java | 2 +- .../apache/hadoop/hive/serde2/WriteBuffers.java | 25 +- .../hive/serde2/avro/AvroDeserializer.java | 2 +- .../hadoop/hive/serde2/avro/AvroSerDe.java | 6 +- .../fast/BinarySortableDeserializeRead.java | 39 +- .../lazy/fast/LazySimpleDeserializeRead.java | 4 +- .../hive/serde2/lazy/fast/StringToDouble.java | 21 +- .../hive/serde2/lazybinary/LazyBinaryUtils.java | 2 +- .../objectinspector/ObjectInspectorFactory.java | 11 +- .../StandardStructObjectInspector.java | 2 +- .../hive/serde2/typeinfo/TypeInfoUtils.java | 2 +- .../hive/serde2/TestColumnProjectionUtils.java | 14 + .../binarysortable/TestBinarySortableFast.java | 13 +- service-rpc/pom.xml | 2 +- service/pom.xml | 100 +- .../org/apache/hive/tmpl/QueryProfileTmpl.jamon | 10 +- .../hive/service/cli/JobProgressUpdate.java | 17 + .../cli/ProgressMonitorStatusMapper.java | 17 + .../cli/TezProgressMonitorStatusMapper.java | 17 + .../cli/operation/HiveCommandOperation.java | 8 +- .../cli/operation/LogDivertAppender.java | 249 - .../hive/service/cli/operation/Operation.java | 73 +- .../service/cli/operation/OperationManager.java | 32 +- .../service/cli/operation/SQLOperation.java | 40 +- .../service/cli/session/HiveSessionImpl.java | 46 +- .../service/cli/session/SessionManager.java | 4 +- .../cli/thrift/ThriftHttpCLIService.java | 33 +- .../hive-webapps/hiveserver2/hiveserver2.jsp | 8 +- .../hive/service/server/TestHS2HttpServer.java | 9 +- shims/0.23/pom.xml | 6 +- .../apache/hadoop/hive/shims/Hadoop23Shims.java | 16 +- shims/aggregator/pom.xml | 2 +- shims/common/pom.xml | 7 +- .../org/apache/hadoop/hive/io/HdfsUtils.java | 4 +- .../hive/io/HiveIOExceptionHandlerChain.java | 2 +- .../hive/io/HiveIOExceptionHandlerUtil.java | 4 +- .../apache/hadoop/hive/shims/ShimLoader.java | 2 +- shims/pom.xml | 2 +- shims/scheduler/pom.xml | 8 +- spark-client/pom.xml | 6 +- .../hive/spark/client/SparkClientUtilities.java | 3 +- .../org/apache/hive/spark/client/rpc/Rpc.java | 3 +- .../apache/hive/spark/client/rpc/RpcServer.java | 2 +- storage-api/LICENSE | 203 + storage-api/NOTICE | 6 + storage-api/pom.xml | 4 +- .../hive/common/type/FastHiveDecimalImpl.java | 143 +- .../hadoop/hive/common/type/RandomTypeUtil.java | 10 +- .../hive/ql/exec/vector/VectorizedRowBatch.java | 42 + .../hadoop/hive/ql/util/JavaDataModel.java | 26 +- .../org/apache/hive/common/util/Murmur3.java | 98 +- .../ql/exec/vector/TestStructColumnVector.java | 3 +- .../apache/hive/common/util/TestMurmur3.java | 24 + testutils/pom.xml | 2 +- .../ptest2/conf/cloudhost.properties.example | 19 +- .../hive/testutils/jdbc/HiveBurnInClient.java | 4 +- vector-code-gen/pom.xml | 2 +- 1976 files changed, 172237 insertions(+), 76973 deletions(-) ----------------------------------------------------------------------
