You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dm...@apache.org on 2015/10/30 13:34:58 UTC
[2/2] hive git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/hive
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/hive
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/fbe31ed2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/fbe31ed2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/fbe31ed2
Branch: refs/heads/master
Commit: fbe31ed27cf56472660846ef43e4c2297b3cd9f4
Parents: 080d279 215c577
Author: Dmitry Tolpeko <dm...@gmail.com>
Authored: Fri Oct 30 05:34:27 2015 -0700
Committer: Dmitry Tolpeko <dm...@gmail.com>
Committed: Fri Oct 30 05:34:27 2015 -0700
----------------------------------------------------------------------
accumulo-handler/pom.xml | 65 +-
.../hadoop/hive/accumulo/LazyAccumuloRow.java | 5 +-
.../org/apache/hadoop/hive/accumulo/Utils.java | 5 +-
.../hive/accumulo/columns/ColumnMapper.java | 5 +-
.../accumulo/columns/ColumnMappingFactory.java | 5 +-
.../columns/HiveAccumuloColumnMapping.java | 5 +-
.../hive/accumulo/mr/HiveAccumuloSplit.java | 5 +-
.../predicate/AccumuloPredicateHandler.java | 5 +-
.../predicate/PrimitiveComparisonFilter.java | 5 +-
.../hive/accumulo/predicate/PushdownTuple.java | 5 +-
.../predicate/compare/StringCompare.java | 3 -
.../accumulo/serde/AccumuloRowSerializer.java | 5 +-
.../accumulo/serde/AccumuloSerDeParameters.java | 5 +-
.../serde/CompositeAccumuloRowIdFactory.java | 5 +-
.../predicate/TestAccumuloPredicateHandler.java | 3 -
.../serde/DelimitedAccumuloRowIdFactory.java | 5 +-
.../serde/FirstCharAccumuloCompositeRowId.java | 5 +-
.../hive/accumulo/serde/TestAccumuloSerDe.java | 3 -
beeline/pom.xml | 49 +-
.../java/org/apache/hive/beeline/BeeLine.java | 26 +-
.../apache/hive/beeline/ClassNameCompleter.java | 6 +-
.../org/apache/hive/beeline/SQLCompleter.java | 6 +-
.../apache/hive/beeline/util/QFileClient.java | 8 +-
.../hive/beeline/TestBeelineArgParsing.java | 24 +-
.../apache/hive/beeline/cli/TestHiveCli.java | 6 +-
bin/ext/util/execHiveCmd.sh | 19 +-
cli/pom.xml | 68 +-
.../org/apache/hadoop/hive/cli/CliDriver.java | 13 +-
.../hadoop/hive/cli/OptionsProcessor.java | 6 +-
common/pom.xml | 51 +-
.../hadoop/hive/common/CallableWithNdc.java | 44 -
.../hadoop/hive/common/CompressionUtils.java | 22 +-
.../apache/hadoop/hive/common/FileUtils.java | 8 +-
.../hadoop/hive/common/JvmPauseMonitor.java | 11 +-
.../org/apache/hadoop/hive/common/LogUtils.java | 6 +-
.../hadoop/hive/common/RunnableWithNdc.java | 43 -
.../apache/hadoop/hive/common/ServerUtils.java | 6 +-
.../common/jsonexplain/tez/TezJsonParser.java | 8 +-
.../metrics/metrics2/CodahaleMetrics.java | 17 +-
.../org/apache/hadoop/hive/conf/HiveConf.java | 41 +-
.../hadoop/hive/conf/SystemVariables.java | 6 +-
.../hadoop/hive/conf/VariableSubstitution.java | 8 +-
.../apache/hadoop/hive/ql/log/PerfLogger.java | 8 +-
.../java/org/apache/hive/common/HiveCompat.java | 6 +-
.../hive/common/util/FixedSizedObjectPool.java | 6 +-
.../hive/common/util/HiveStringUtils.java | 2 +-
.../apache/hive/common/util/HiveTestUtils.java | 8 +-
.../hive/common/util/HiveVersionInfo.java | 6 +-
.../hive/common/util/ShutdownHookManager.java | 6 +-
.../apache/hadoop/hive/conf/TestHiveConf.java | 25 +
.../common/util/TestFixedSizedObjectPool.java | 9 +-
contrib/pom.xml | 45 +-
.../genericudf/example/GenericUDFDBOutput.java | 8 +-
.../hive/contrib/serde2/MultiDelimitSerDe.java | 5 +-
.../hadoop/hive/contrib/serde2/RegexSerDe.java | 6 +-
.../hive/contrib/serde2/TypedBytesSerDe.java | 6 +-
.../contrib/serde2/s3/S3LogDeserializer.java | 6 +-
errata.txt | 2 +-
hbase-handler/pom.xml | 247 +--
.../AbstractHBaseKeyPredicateDecomposer.java | 8 +-
.../hive/hbase/CompositeHBaseKeyFactory.java | 8 +-
.../hive/hbase/HBaseLazyObjectFactory.java | 28 +
.../apache/hadoop/hive/hbase/HBaseSerDe.java | 11 +-
.../hadoop/hive/hbase/HBaseSerDeHelper.java | 8 +-
.../hadoop/hive/hbase/HBaseStorageHandler.java | 6 +-
.../HBaseTableSnapshotInputFormatUtil.java | 6 +-
.../hive/hbase/HiveHBaseTableInputFormat.java | 111 +-
.../hive/hbase/HiveHBaseTableOutputFormat.java | 15 +-
.../hive/hbase/HiveHFileOutputFormat.java | 6 +-
.../src/test/queries/positive/hbase_queries.q | 4 +-
.../results/positive/external_table_ppd.q.out | 16 +-
.../positive/hbase_binary_storage_queries.q.out | 32 +-
.../test/results/positive/hbase_queries.q.out | 37 +-
.../test/results/positive/hbase_timestamp.q.out | 6 +-
.../positive/hbase_timestamp_format.q.out | 12 +-
hcatalog/core/pom.xml | 194 +-
.../org/apache/hive/hcatalog/cli/HCatCli.java | 8 +-
.../mapreduce/HCatBaseOutputFormat.java | 2 -
.../hive/hcatalog/mapreduce/SpecialCases.java | 6 +-
hcatalog/hcatalog-pig-adapter/pom.xml | 160 +-
.../hcatalog/pig/TestHCatLoaderEncryption.java | 61 +-
hcatalog/pom.xml | 65 +-
hcatalog/server-extensions/pom.xml | 29 +-
.../listener/DbNotificationListener.java | 6 +-
.../messaging/json/JSONMessageFactory.java | 6 +-
hcatalog/streaming/pom.xml | 42 +-
.../streaming/AbstractRecordWriter.java | 6 +-
.../streaming/DelimitedInputWriter.java | 6 +-
.../hive/hcatalog/streaming/HiveEndPoint.java | 6 +-
.../hive/hcatalog/streaming/InvalidTable.java | 4 +-
.../streaming/StreamingIntegrationTester.java | 6 +-
hcatalog/webhcat/java-client/pom.xml | 39 +-
.../hive/hcatalog/api/TestHCatClient.java | 39 +-
.../hcatalog/api/repl/CommandTestUtils.java | 6 +-
.../api/repl/commands/TestCommands.java | 6 +-
hcatalog/webhcat/svr/pom.xml | 60 +-
.../hive/hcatalog/templeton/AppConfig.java | 6 +-
.../templeton/CatchallExceptionMapper.java | 6 +-
.../hcatalog/templeton/CompleteDelegator.java | 6 +-
.../hcatalog/templeton/DeleteDelegator.java | 6 +-
.../hcatalog/templeton/ExecServiceImpl.java | 6 +-
.../hive/hcatalog/templeton/HcatDelegator.java | 6 +-
.../hcatalog/templeton/LauncherDelegator.java | 6 +-
.../apache/hive/hcatalog/templeton/Main.java | 10 +-
.../hive/hcatalog/templeton/PigDelegator.java | 6 +-
.../hcatalog/templeton/ProxyUserSupport.java | 6 +-
.../hcatalog/templeton/SecureProxySupport.java | 6 +-
.../apache/hive/hcatalog/templeton/Server.java | 6 +-
.../hive/hcatalog/templeton/SqoopDelegator.java | 6 +-
.../hcatalog/templeton/StatusDelegator.java | 6 +-
.../hcatalog/templeton/tool/HDFSCleanup.java | 6 +-
.../hcatalog/templeton/tool/HDFSStorage.java | 6 +-
.../hive/hcatalog/templeton/tool/JobState.java | 6 +-
.../templeton/tool/JobStateTracker.java | 6 +-
.../hcatalog/templeton/tool/LaunchMapper.java | 8 +-
.../hcatalog/templeton/tool/LogRetriever.java | 6 +-
.../templeton/tool/TempletonControllerJob.java | 6 +-
.../hcatalog/templeton/tool/TempletonUtils.java | 6 +-
.../templeton/tool/TrivialExecService.java | 6 +-
.../templeton/tool/ZooKeeperCleanup.java | 6 +-
.../templeton/tool/ZooKeeperStorage.java | 6 +-
hplsql/pom.xml | 36 +-
hwi/pom.xml | 66 +-
.../hadoop/hive/hwi/HWIContextListener.java | 6 +-
.../org/apache/hadoop/hive/hwi/HWIServer.java | 8 +-
.../apache/hadoop/hive/hwi/HWISessionItem.java | 8 +-
.../hadoop/hive/hwi/HWISessionManager.java | 6 +-
itests/custom-serde/pom.xml | 31 +-
...CustomNonSettableStructObjectInspector1.java | 8 +-
itests/hcatalog-unit/pom.xml | 389 ++--
.../api/TestHCatClientNotification.java | 6 +-
.../listener/TestDbNotificationListener.java | 8 +-
itests/hive-jmh/pom.xml | 38 +-
itests/hive-minikdc/pom.xml | 181 +-
itests/hive-unit-hadoop2/pom.xml | 12 +-
.../hive/thrift/TestHadoopAuthBridge23.java | 27 +-
itests/hive-unit/pom.xml | 353 ++--
.../hive/metastore/TestHiveMetaStore.java | 6 +-
.../hive/metastore/TestHiveMetaStoreTxns.java | 3 +-
...TestHiveMetaStoreWithEnvironmentContext.java | 11 +-
.../hive/metastore/TestMetastoreVersion.java | 6 +-
.../metastore/hbase/HBaseIntegrationTests.java | 6 +-
.../TestHBaseAggrStatsCacheIntegration.java | 6 +-
.../hive/metastore/hbase/TestHBaseImport.java | 6 +-
.../metastore/hbase/TestHBaseMetastoreSql.java | 6 +-
.../metastore/hbase/TestHBaseSchemaTool.java | 584 ++++++
.../metastore/hbase/TestHBaseSchemaTool2.java | 61 +
.../hbase/TestHBaseStoreIntegration.java | 6 +-
.../hbase/TestStorageDescriptorSharing.java | 6 +-
.../TestHiveAuthorizerCheckInvocation.java | 6 +-
.../hive/beeline/TestBeeLineWithArgs.java | 8 +
.../org/apache/hive/jdbc/TestJdbcDriver2.java | 6 +-
.../hive/jdbc/cbo_rp_TestJdbcDriver2.java | 6 +-
itests/pom.xml | 9 +-
itests/qtest-accumulo/pom.xml | 400 ++--
itests/qtest-spark/pom.xml | 43 +-
itests/qtest/pom.xml | 549 +++---
itests/test-serde/pom.xml | 32 +-
.../apache/hadoop/hive/serde2/TestSerDe.java | 6 +-
itests/util/pom.xml | 163 +-
.../org/apache/hadoop/hive/ql/QTestUtil.java | 10 +-
.../hive/ql/hooks/CheckColumnAccessHook.java | 4 +-
...DummyHiveMetastoreAuthorizationProvider.java | 6 +-
...SQLStdHiveAuthorizationValidatorForTest.java | 47 +-
.../hadoop/hive/ql/udf/UDFFileLookup.java | 4 -
.../hive/ql/udf/generic/GenericUDAFSumList.java | 6 +-
jdbc/pom.xml | 40 +-
.../org/apache/hive/jdbc/HiveConnection.java | 6 +-
.../org/apache/hive/jdbc/HiveDataSource.java | 24 +-
.../java/org/apache/hive/jdbc/HiveDriver.java | 6 +
.../apache/hive/jdbc/HiveQueryResultSet.java | 6 +-
.../org/apache/hive/jdbc/HiveStatement.java | 7 +-
jdbc/src/java/org/apache/hive/jdbc/Utils.java | 8 +-
.../hive/jdbc/ZooKeeperHiveClientHelper.java | 7 +-
llap-client/pom.xml | 101 +-
.../hive/llap/registry/ServiceInstance.java | 73 +
.../hive/llap/registry/ServiceInstanceSet.java | 57 +
.../hive/llap/registry/ServiceRegistry.java | 59 +
.../registry/impl/LlapFixedRegistryImpl.java | 223 +++
.../llap/registry/impl/LlapRegistryService.java | 87 +
.../registry/impl/LlapYarnRegistryImpl.java | 383 ++++
llap-server/pom.xml | 145 +-
.../hadoop/hive/llap/cache/BuddyAllocator.java | 11 +-
.../hive/llap/cache/LowLevelCacheImpl.java | 13 +-
.../llap/cache/LowLevelCacheMemoryManager.java | 5 +-
.../llap/cache/LowLevelFifoCachePolicy.java | 7 +-
.../llap/cache/LowLevelLrfuCachePolicy.java | 7 +-
.../hive/llap/cli/LlapOptionsProcessor.java | 6 +-
.../hadoop/hive/llap/cli/LlapServiceDriver.java | 6 +-
.../hadoop/hive/llap/daemon/HistoryLogger.java | 5 +-
.../hive/llap/daemon/impl/AMReporter.java | 6 +-
.../hive/llap/daemon/impl/LlapDaemon.java | 2 +-
.../impl/LlapDaemonProtocolServerImpl.java | 6 +-
.../llap/daemon/impl/TaskRunnerCallable.java | 2 +-
.../llap/daemon/registry/ServiceInstance.java | 73 -
.../daemon/registry/ServiceInstanceSet.java | 57 -
.../llap/daemon/registry/ServiceRegistry.java | 59 -
.../registry/impl/LlapFixedRegistryImpl.java | 222 ---
.../registry/impl/LlapRegistryService.java | 86 -
.../registry/impl/LlapYarnRegistryImpl.java | 383 ----
.../daemon/services/impl/LlapWebServices.java | 2 -
.../hive/llap/io/api/impl/LlapInputFormat.java | 5 +-
.../hive/llap/io/api/impl/LlapIoImpl.java | 22 +-
.../llap/io/decode/EncodedDataConsumer.java | 4 +-
.../llap/io/decode/OrcColumnVectorProducer.java | 9 +-
.../llap/io/encoded/OrcEncodedDataReader.java | 17 +-
.../hive/llap/shufflehandler/DirWatcher.java | 6 +-
.../shufflehandler/FadvisedChunkedFile.java | 6 +-
.../llap/shufflehandler/FadvisedFileRegion.java | 6 +-
.../hive/llap/shufflehandler/IndexCache.java | 6 +-
.../llap/shufflehandler/ShuffleHandler.java | 6 +-
.../tezplugins/helpers/SourceStateTracker.java | 6 +-
.../dag/app/rm/LlapTaskSchedulerService.java | 6 +-
.../hive/llap/cache/TestBuddyAllocator.java | 6 +-
.../TestIncrementalObjectSizeEstimator.java | 6 +-
.../hive/llap/cache/TestLowLevelCacheImpl.java | 6 +-
.../llap/cache/TestLowLevelLrfuCachePolicy.java | 6 +-
.../hive/llap/cache/TestOrcMetadataCache.java | 4 +-
.../hive/llap/daemon/MiniLlapCluster.java | 6 +-
.../app/rm/TestLlapTaskSchedulerService.java | 2 +-
metastore/if/hive_metastore.thrift | 8 +-
metastore/pom.xml | 80 +-
.../gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 1744 +++++++++---------
.../gen/thrift/gen-cpp/hive_metastore_types.cpp | 402 ++--
.../gen/thrift/gen-cpp/hive_metastore_types.h | 20 +-
.../metastore/api/FileMetadataExprType.java | 42 +
.../api/GetFileMetadataByExprRequest.java | 126 +-
.../src/gen/thrift/gen-php/metastore/Types.php | 30 +
.../gen/thrift/gen-py/hive_metastore/ttypes.py | 26 +-
.../gen/thrift/gen-rb/hive_metastore_types.rb | 13 +-
.../hive/metastore/AggregateStatsCache.java | 32 +-
.../apache/hadoop/hive/metastore/Deadline.java | 6 +-
.../hive/metastore/FileMetadataHandler.java | 30 +
.../hadoop/hive/metastore/HiveAlterHandler.java | 12 +-
.../hadoop/hive/metastore/HiveMetaStore.java | 35 +-
.../hive/metastore/HiveMetaStoreClient.java | 6 +-
.../hive/metastore/HiveMetaStoreFsImpl.java | 8 +-
.../hive/metastore/MetaStoreDirectSql.java | 6 +-
.../hadoop/hive/metastore/MetaStoreInit.java | 6 +-
.../hadoop/hive/metastore/MetaStoreUtils.java | 16 +-
.../hadoop/hive/metastore/ObjectStore.java | 15 +-
.../hive/metastore/PartFilterExprUtil.java | 6 +-
.../apache/hadoop/hive/metastore/RawStore.java | 8 +-
.../hadoop/hive/metastore/RawStoreProxy.java | 6 -
.../hive/metastore/RetryingHMSHandler.java | 6 +-
.../hive/metastore/RetryingMetaStoreClient.java | 6 +-
.../hive/metastore/TUGIBasedProcessor.java | 6 +-
.../apache/hadoop/hive/metastore/Warehouse.java | 6 +-
.../hive/metastore/events/EventCleanerTask.java | 8 +-
.../filemeta/OrcFileMetadataHandler.java | 63 +
.../hbase/AggrStatsInvalidatorFilter.java | 8 +-
.../hive/metastore/hbase/HBaseImport.java | 6 +-
.../hive/metastore/hbase/HBaseReadWrite.java | 706 +++++--
.../hive/metastore/hbase/HBaseSchemaTool.java | 282 ++-
.../hadoop/hive/metastore/hbase/HBaseStore.java | 47 +-
.../hadoop/hive/metastore/hbase/HBaseUtils.java | 109 +-
.../metastore/hbase/PartitionKeyComparator.java | 6 +-
.../hbase/SharedStorageDescriptor.java | 6 +-
.../hadoop/hive/metastore/hbase/StatsCache.java | 6 +-
.../metastore/hbase/TephraHBaseConnection.java | 6 +-
.../metastore/hbase/VanillaHBaseConnection.java | 6 +-
.../spec/CompositePartitionSpecProxy.java | 4 +-
.../hive/metastore/tools/HiveMetaTool.java | 6 +-
.../metastore/txn/CompactionTxnHandler.java | 6 +-
.../hadoop/hive/metastore/txn/TxnDbUtil.java | 6 +-
.../hadoop/hive/metastore/txn/TxnHandler.java | 6 +-
.../metastore/DummyMetaStoreInitListener.java | 4 +-
.../DummyRawStoreControlledCommit.java | 3 +-
.../DummyRawStoreForJdoConnection.java | 3 +-
.../hive/metastore/VerifyingObjectStore.java | 6 +-
.../hbase/TestHBaseAggregateStatsCache.java | 6 +-
.../hive/metastore/hbase/TestHBaseStore.java | 6 +-
.../metastore/hbase/TestHBaseStoreCached.java | 6 +-
.../hbase/TestSharedStorageDescriptor.java | 6 +-
.../metastore/txn/TestTxnHandlerNegative.java | 6 +-
pom.xml | 250 +--
ql/pom.xml | 164 +-
.../org/apache/hadoop/hive/llap/LogLevels.java | 53 -
.../java/org/apache/hadoop/hive/ql/Context.java | 10 +-
.../java/org/apache/hadoop/hive/ql/Driver.java | 23 +-
.../apache/hadoop/hive/ql/DriverContext.java | 8 +-
.../org/apache/hadoop/hive/ql/QueryPlan.java | 3 -
.../apache/hadoop/hive/ql/QueryProperties.java | 10 -
.../hive/ql/exec/AbstractFileMergeOperator.java | 9 +-
.../hadoop/hive/ql/exec/ArchiveUtils.java | 6 +-
.../hadoop/hive/ql/exec/AutoProgressor.java | 6 +-
.../hadoop/hive/ql/exec/ColumnStatsTask.java | 6 +-
.../hive/ql/exec/ColumnStatsUpdateTask.java | 10 +-
.../hadoop/hive/ql/exec/CommonJoinOperator.java | 6 +-
.../hive/ql/exec/CommonMergeJoinOperator.java | 6 +-
.../apache/hadoop/hive/ql/exec/CopyTask.java | 6 +-
.../org/apache/hadoop/hive/ql/exec/DDLTask.java | 6 +-
.../hive/ql/exec/DefaultBucketMatcher.java | 6 +-
.../hadoop/hive/ql/exec/DemuxOperator.java | 6 +-
.../apache/hadoop/hive/ql/exec/ExplainTask.java | 8 +-
.../ql/exec/ExprNodeGenericFuncEvaluator.java | 8 +-
.../hadoop/hive/ql/exec/FetchOperator.java | 7 +-
.../apache/hadoop/hive/ql/exec/FetchTask.java | 6 +-
.../hadoop/hive/ql/exec/FileSinkOperator.java | 9 +-
.../hadoop/hive/ql/exec/FunctionRegistry.java | 12 +-
.../hadoop/hive/ql/exec/FunctionTask.java | 10 +-
.../hive/ql/exec/HashTableSinkOperator.java | 8 +-
.../apache/hadoop/hive/ql/exec/Heartbeater.java | 6 +-
.../hive/ql/exec/HiveTotalOrderPartitioner.java | 6 +-
.../hadoop/hive/ql/exec/JoinOperator.java | 6 +-
.../hadoop/hive/ql/exec/MapJoinOperator.java | 16 +-
.../hadoop/hive/ql/exec/MapredContext.java | 6 +-
.../apache/hadoop/hive/ql/exec/MoveTask.java | 6 +-
.../apache/hadoop/hive/ql/exec/MuxOperator.java | 6 +-
.../hadoop/hive/ql/exec/ObjectCacheFactory.java | 6 +-
.../apache/hadoop/hive/ql/exec/Operator.java | 8 +-
.../hadoop/hive/ql/exec/OperatorFactory.java | 6 +-
.../hadoop/hive/ql/exec/OperatorUtils.java | 6 +-
.../hive/ql/exec/OrcFileMergeOperator.java | 6 +-
.../hadoop/hive/ql/exec/PTFPartition.java | 6 +-
.../hive/ql/exec/PartitionKeySampler.java | 6 +-
.../hive/ql/exec/RCFileMergeOperator.java | 6 +-
.../apache/hadoop/hive/ql/exec/Registry.java | 6 +-
.../hadoop/hive/ql/exec/SMBMapJoinOperator.java | 8 +-
.../hadoop/hive/ql/exec/SkewJoinHandler.java | 8 +-
.../ql/exec/SparkHashTableSinkOperator.java | 6 +-
.../hadoop/hive/ql/exec/StatsNoJobTask.java | 6 +-
.../apache/hadoop/hive/ql/exec/StatsTask.java | 6 +-
.../org/apache/hadoop/hive/ql/exec/Task.java | 6 +-
.../apache/hadoop/hive/ql/exec/TopNHash.java | 6 +-
.../hadoop/hive/ql/exec/UDTFOperator.java | 6 +-
.../apache/hadoop/hive/ql/exec/Utilities.java | 24 +-
.../hive/ql/exec/errors/TaskLogProcessor.java | 6 +-
.../mapjoin/MapJoinMemoryExhaustionHandler.java | 6 +-
.../hadoop/hive/ql/exec/mr/ExecDriver.java | 18 +-
.../hadoop/hive/ql/exec/mr/ExecMapper.java | 18 +-
.../hive/ql/exec/mr/ExecMapperContext.java | 3 -
.../hadoop/hive/ql/exec/mr/ExecReducer.java | 8 +-
.../hadoop/hive/ql/exec/mr/HashTableLoader.java | 6 +-
.../hadoop/hive/ql/exec/mr/MapredLocalTask.java | 8 +-
.../hadoop/hive/ql/exec/mr/ObjectCache.java | 6 +-
.../apache/hadoop/hive/ql/exec/mr/Throttle.java | 4 +-
.../persistence/BytesBytesMultiHashMap.java | 6 +-
.../ql/exec/persistence/FlatRowContainer.java | 6 +-
.../ql/exec/persistence/HashMapWrapper.java | 6 +-
.../persistence/HybridHashTableContainer.java | 53 +-
.../ql/exec/persistence/KeyValueContainer.java | 6 +-
.../persistence/MapJoinBytesTableContainer.java | 6 +-
.../hive/ql/exec/persistence/MapJoinKey.java | 4 +-
.../ql/exec/persistence/ObjectContainer.java | 6 +-
.../hive/ql/exec/persistence/RowContainer.java | 6 +-
.../hive/ql/exec/spark/HashTableLoader.java | 6 +-
.../hive/ql/exec/spark/HiveKVResultCache.java | 6 +-
.../ql/exec/spark/HiveSparkClientFactory.java | 6 +-
.../hive/ql/exec/spark/KryoSerializer.java | 6 +-
.../ql/exec/spark/LocalHiveSparkClient.java | 16 +-
.../ql/exec/spark/RemoteHiveSparkClient.java | 6 +-
.../hive/ql/exec/spark/SmallTableCache.java | 6 +-
.../exec/spark/SparkDynamicPartitionPruner.java | 6 +-
.../ql/exec/spark/SparkMapRecordHandler.java | 9 +-
.../exec/spark/SparkMergeFileRecordHandler.java | 6 +-
.../hadoop/hive/ql/exec/spark/SparkPlan.java | 8 +-
.../hive/ql/exec/spark/SparkPlanGenerator.java | 6 +-
.../hive/ql/exec/spark/SparkRecordHandler.java | 10 +-
.../ql/exec/spark/SparkReduceRecordHandler.java | 8 +-
.../hadoop/hive/ql/exec/spark/SparkTask.java | 8 +-
.../ql/exec/spark/session/SparkSessionImpl.java | 6 +-
.../spark/session/SparkSessionManagerImpl.java | 6 +-
.../ql/exec/spark/status/SparkJobMonitor.java | 8 +-
.../spark/status/impl/JobMetricsListener.java | 6 +-
.../spark/status/impl/LocalSparkJobStatus.java | 6 +-
.../spark/status/impl/RemoteSparkJobStatus.java | 6 +-
.../ql/exec/tez/ColumnarSplitSizeEstimator.java | 6 +-
.../hive/ql/exec/tez/CustomPartitionEdge.java | 6 +-
.../hive/ql/exec/tez/CustomPartitionVertex.java | 6 +-
.../hadoop/hive/ql/exec/tez/DagUtils.java | 8 +-
.../ql/exec/tez/DynamicPartitionPruner.java | 6 +-
.../hive/ql/exec/tez/HashTableLoader.java | 6 +-
.../hive/ql/exec/tez/HivePreWarmProcessor.java | 6 +-
.../hive/ql/exec/tez/HiveSplitGenerator.java | 6 +-
.../hive/ql/exec/tez/LlapObjectCache.java | 6 +-
.../hive/ql/exec/tez/MapRecordProcessor.java | 6 +-
.../hive/ql/exec/tez/MapRecordSource.java | 8 +-
.../ql/exec/tez/MergeFileRecordProcessor.java | 10 +-
.../hadoop/hive/ql/exec/tez/ObjectCache.java | 6 +-
.../hive/ql/exec/tez/RecordProcessor.java | 7 +-
.../hive/ql/exec/tez/ReduceRecordProcessor.java | 6 +-
.../hive/ql/exec/tez/ReduceRecordSource.java | 10 +-
.../hadoop/hive/ql/exec/tez/SplitGrouper.java | 6 +-
.../hive/ql/exec/tez/TezJobExecHelper.java | 6 +-
.../hadoop/hive/ql/exec/tez/TezProcessor.java | 7 +-
.../hive/ql/exec/tez/TezSessionPoolManager.java | 6 +-
.../hive/ql/exec/tez/TezSessionState.java | 12 +-
.../ql/exec/tez/tools/KeyValueInputMerger.java | 6 +-
.../ql/exec/tez/tools/KeyValuesInputMerger.java | 6 +-
.../hive/ql/exec/vector/VectorAssignRow.java | 8 +-
.../ql/exec/vector/VectorColumnOrderedMap.java | 6 +-
.../hive/ql/exec/vector/VectorCopyRow.java | 8 +-
.../ql/exec/vector/VectorDeserializeRow.java | 8 +-
.../exec/vector/VectorExpressionDescriptor.java | 6 +-
.../hive/ql/exec/vector/VectorExtractRow.java | 8 +-
.../ql/exec/vector/VectorGroupByOperator.java | 6 +-
.../exec/vector/VectorMapJoinBaseOperator.java | 8 +-
.../ql/exec/vector/VectorMapJoinOperator.java | 6 +-
.../exec/vector/VectorSMBMapJoinOperator.java | 6 +-
.../exec/vector/VectorSerializeRowNoNulls.java | 8 +-
.../ql/exec/vector/VectorizationContext.java | 6 +-
.../ql/exec/vector/VectorizedBatchUtil.java | 6 +-
.../ql/exec/vector/VectorizedRowBatchCtx.java | 6 +-
.../vector/expressions/VectorUDFDateString.java | 6 +-
.../mapjoin/VectorMapJoinCommonOperator.java | 8 +-
.../VectorMapJoinGenerateResultOperator.java | 8 +-
...pJoinInnerBigOnlyGenerateResultOperator.java | 8 +-
.../VectorMapJoinInnerBigOnlyLongOperator.java | 6 +-
...ctorMapJoinInnerBigOnlyMultiKeyOperator.java | 6 +-
...VectorMapJoinInnerBigOnlyStringOperator.java | 6 +-
...ectorMapJoinInnerGenerateResultOperator.java | 8 +-
.../mapjoin/VectorMapJoinInnerLongOperator.java | 6 +-
.../VectorMapJoinInnerMultiKeyOperator.java | 6 +-
.../VectorMapJoinInnerStringOperator.java | 6 +-
...orMapJoinLeftSemiGenerateResultOperator.java | 8 +-
.../VectorMapJoinLeftSemiLongOperator.java | 6 +-
.../VectorMapJoinLeftSemiMultiKeyOperator.java | 6 +-
.../VectorMapJoinLeftSemiStringOperator.java | 6 +-
...ectorMapJoinOuterGenerateResultOperator.java | 8 +-
.../mapjoin/VectorMapJoinOuterLongOperator.java | 6 +-
.../VectorMapJoinOuterMultiKeyOperator.java | 6 +-
.../VectorMapJoinOuterStringOperator.java | 6 +-
.../mapjoin/VectorMapJoinRowBytesContainer.java | 6 +-
.../fast/VectorMapJoinFastBytesHashMap.java | 8 +-
.../VectorMapJoinFastBytesHashMultiSet.java | 8 +-
.../fast/VectorMapJoinFastBytesHashSet.java | 8 +-
.../fast/VectorMapJoinFastBytesHashTable.java | 8 +-
.../fast/VectorMapJoinFastHashTable.java | 8 +-
.../fast/VectorMapJoinFastHashTableLoader.java | 8 +-
.../mapjoin/fast/VectorMapJoinFastKeyStore.java | 8 +-
.../fast/VectorMapJoinFastLongHashMap.java | 8 +-
.../fast/VectorMapJoinFastLongHashMultiSet.java | 8 +-
.../fast/VectorMapJoinFastLongHashSet.java | 8 +-
.../fast/VectorMapJoinFastLongHashTable.java | 8 +-
.../fast/VectorMapJoinFastTableContainer.java | 8 +-
.../fast/VectorMapJoinFastValueStore.java | 8 +-
.../VectorMapJoinOptimizedCreateHashTable.java | 8 +-
.../VectorMapJoinOptimizedHashTable.java | 6 +-
.../VectorMapJoinOptimizedLongCommon.java | 8 +-
.../hadoop/hive/ql/history/HiveHistoryImpl.java | 8 +-
.../hive/ql/history/HiveHistoryViewer.java | 6 +-
.../apache/hadoop/hive/ql/hooks/ATSHook.java | 6 +-
.../hadoop/hive/ql/hooks/LineageLogger.java | 15 +-
.../hive/ql/hooks/PostExecOrcFileDump.java | 6 +-
.../ql/hooks/PostExecTezSummaryPrinter.java | 6 +-
.../hadoop/hive/ql/hooks/WriteEntity.java | 6 +-
.../apache/hadoop/hive/ql/index/HiveIndex.java | 6 +-
.../hadoop/hive/ql/index/HiveIndexResult.java | 8 +-
.../hive/ql/index/HiveIndexedInputFormat.java | 6 +-
.../ql/index/bitmap/BitmapIndexHandler.java | 6 +-
.../ql/index/compact/CompactIndexHandler.java | 6 +-
.../compact/HiveCompactIndexInputFormat.java | 8 +-
.../org/apache/hadoop/hive/ql/io/AcidUtils.java | 6 +-
.../hive/ql/io/BucketizedHiveInputFormat.java | 8 +-
.../org/apache/hadoop/hive/ql/io/CodecPool.java | 6 +-
.../hive/ql/io/CombineHiveInputFormat.java | 6 +-
.../org/apache/hadoop/hive/ql/io/HdfsUtils.java | 6 +-
.../ql/io/HiveContextAwareRecordReader.java | 6 +-
.../hadoop/hive/ql/io/HiveFileFormatUtils.java | 6 +-
.../hadoop/hive/ql/io/HiveInputFormat.java | 6 +-
.../apache/hadoop/hive/ql/io/IOContextMap.java | 6 +-
.../hadoop/hive/ql/io/NullRowsInputFormat.java | 6 +-
.../org/apache/hadoop/hive/ql/io/RCFile.java | 6 +-
.../hadoop/hive/ql/io/StorageFormatFactory.java | 6 +-
.../ql/io/avro/AvroContainerOutputFormat.java | 6 +-
.../ql/io/avro/AvroGenericRecordReader.java | 6 +-
.../hive/ql/io/merge/MergeFileMapper.java | 6 +-
.../hadoop/hive/ql/io/merge/MergeFileTask.java | 2 +-
.../hadoop/hive/ql/io/merge/MergeFileWork.java | 6 +-
.../apache/hadoop/hive/ql/io/orc/FileDump.java | 197 +-
.../apache/hadoop/hive/ql/io/orc/InStream.java | 6 +-
.../hadoop/hive/ql/io/orc/JsonFileDump.java | 216 ++-
.../hadoop/hive/ql/io/orc/MemoryManager.java | 6 +-
.../hadoop/hive/ql/io/orc/OrcInputFormat.java | 23 +-
.../hive/ql/io/orc/OrcNewInputFormat.java | 6 +-
.../hadoop/hive/ql/io/orc/OrcOutputFormat.java | 6 +-
.../hive/ql/io/orc/OrcRawRecordMerger.java | 6 +-
.../hadoop/hive/ql/io/orc/OrcRecordUpdater.java | 40 +-
.../apache/hadoop/hive/ql/io/orc/OrcSerde.java | 6 +-
.../apache/hadoop/hive/ql/io/orc/OrcSplit.java | 6 +-
.../apache/hadoop/hive/ql/io/orc/OrcUtils.java | 6 +-
.../hadoop/hive/ql/io/orc/ReaderImpl.java | 8 +-
.../hive/ql/io/orc/RecordReaderFactory.java | 6 +-
.../hadoop/hive/ql/io/orc/RecordReaderImpl.java | 6 +-
.../ql/io/orc/RunLengthIntegerReaderV2.java | 6 +-
.../hadoop/hive/ql/io/orc/WriterImpl.java | 6 +-
.../ql/io/orc/encoded/EncodedReaderImpl.java | 6 +-
.../hive/ql/io/parquet/LeafFilterFactory.java | 6 +-
.../ql/io/parquet/MapredParquetInputFormat.java | 6 +-
.../io/parquet/MapredParquetOutputFormat.java | 6 +-
.../hive/ql/io/parquet/ProjectionPusher.java | 6 +-
.../parquet/VectorizedParquetInputFormat.java | 8 +-
.../read/ParquetFilterPredicateConverter.java | 6 +-
.../read/ParquetRecordReaderWrapper.java | 6 +-
.../ql/io/parquet/write/DataWritableWriter.java | 8 +-
.../write/ParquetRecordWriterWrapper.java | 6 +-
.../ql/io/rcfile/stats/PartialScanMapper.java | 6 +-
.../ql/io/rcfile/stats/PartialScanTask.java | 7 +-
.../rcfile/truncate/ColumnTruncateMapper.java | 6 +-
.../io/rcfile/truncate/ColumnTruncateTask.java | 5 +-
.../hive/ql/io/sarg/ConvertAstToSearchArg.java | 6 +-
.../hadoop/hive/ql/lockmgr/DbLockManager.java | 6 +-
.../hadoop/hive/ql/lockmgr/DbTxnManager.java | 6 +-
.../hadoop/hive/ql/lockmgr/DummyTxnManager.java | 8 +-
.../hive/ql/lockmgr/EmbeddedLockManager.java | 19 +-
.../zookeeper/CuratorFrameworkSingleton.java | 6 +-
.../zookeeper/ZooKeeperHiveLockManager.java | 16 +-
.../hadoop/hive/ql/metadata/DummyPartition.java | 8 +-
.../apache/hadoop/hive/ql/metadata/Hive.java | 23 +-
.../hive/ql/metadata/HiveMetaStoreChecker.java | 6 +-
.../hadoop/hive/ql/metadata/HiveUtils.java | 6 +-
.../hadoop/hive/ql/metadata/Partition.java | 8 +-
.../ql/metadata/SessionHiveMetaStoreClient.java | 20 +-
.../apache/hadoop/hive/ql/metadata/Table.java | 6 +-
.../formatting/JsonMetaDataFormatter.java | 6 +-
.../formatting/TextMetaDataFormatter.java | 6 +-
.../ql/optimizer/AbstractBucketJoinProc.java | 4 -
...tionSizeBasedBigTableSelectorForAutoSMJ.java | 8 +-
.../hive/ql/optimizer/BucketJoinProcCtx.java | 8 +-
.../ql/optimizer/BucketMapJoinOptimizer.java | 6 +-
.../hive/ql/optimizer/ColumnPrunerProcCtx.java | 7 +
.../ql/optimizer/ColumnPrunerProcFactory.java | 6 +-
.../hive/ql/optimizer/ConstantPropagate.java | 6 +-
.../ql/optimizer/ConstantPropagateProcCtx.java | 21 +-
.../optimizer/ConstantPropagateProcFactory.java | 6 +-
.../hive/ql/optimizer/ConvertJoinMapJoin.java | 6 +-
.../DynamicPartitionPruningOptimization.java | 6 +-
.../hive/ql/optimizer/GenMRFileSink1.java | 6 +-
.../hive/ql/optimizer/GenMapRedUtils.java | 11 +-
.../hive/ql/optimizer/GlobalLimitOptimizer.java | 6 +-
.../hive/ql/optimizer/GroupByOptimizer.java | 6 +-
.../ql/optimizer/IdentityProjectRemover.java | 6 +-
.../hadoop/hive/ql/optimizer/IndexUtils.java | 6 +-
.../hive/ql/optimizer/MapJoinProcessor.java | 6 +-
.../ql/optimizer/OperatorComparatorFactory.java | 8 +-
.../hadoop/hive/ql/optimizer/Optimizer.java | 19 +-
.../hive/ql/optimizer/PointLookupOptimizer.java | 6 +-
.../hadoop/hive/ql/optimizer/PrunerUtils.java | 8 -
.../ql/optimizer/ReduceSinkMapJoinProc.java | 6 +-
.../optimizer/RemoveDynamicPruningBySize.java | 6 +-
.../hadoop/hive/ql/optimizer/SamplePruner.java | 8 +-
.../ql/optimizer/SetReducerParallelism.java | 6 +-
.../hive/ql/optimizer/SimpleFetchOptimizer.java | 6 +-
.../hive/ql/optimizer/SkewJoinOptimizer.java | 6 +-
.../optimizer/SortedDynPartitionOptimizer.java | 6 +-
.../SortedMergeBucketMapJoinOptimizer.java | 8 +-
.../SparkRemoveDynamicPruningBySize.java | 8 +-
.../hive/ql/optimizer/StatsOptimizer.java | 88 +-
.../ql/optimizer/calcite/HiveCalciteUtil.java | 6 +-
.../ql/optimizer/calcite/HiveRelOptUtil.java | 6 +-
.../ql/optimizer/calcite/RelOptHiveTable.java | 8 +-
.../optimizer/calcite/cost/HiveCostModel.java | 6 +-
.../calcite/cost/HiveOnTezCostModel.java | 6 +-
.../rules/HiveInsertExchange4JoinRule.java | 8 +-
.../calcite/rules/HiveJoinAddNotNullRule.java | 8 +-
.../calcite/rules/HiveJoinToMultiJoinRule.java | 6 +-
.../calcite/rules/HivePreFilteringRule.java | 10 +-
.../optimizer/calcite/rules/PartitionPrune.java | 6 +-
.../calcite/stats/HiveRelMdRowCount.java | 20 +-
.../calcite/translator/ASTConverter.java | 6 +-
.../calcite/translator/ExprNodeConverter.java | 12 +-
.../calcite/translator/HiveOpConverter.java | 6 +-
.../translator/HiveOpConverterPostProc.java | 6 +-
.../translator/PlanModifierForASTConv.java | 6 +-
.../calcite/translator/PlanModifierUtil.java | 6 +-
.../calcite/translator/RexNodeConverter.java | 6 +-
.../translator/SqlFunctionConverter.java | 6 +-
.../correlation/CorrelationOptimizer.java | 6 +-
.../QueryPlanTreeTransformation.java | 6 +-
.../ql/optimizer/index/RewriteCanApplyCtx.java | 6 +-
.../ql/optimizer/index/RewriteGBUsingIndex.java | 6 +-
.../index/RewriteParseContextGenerator.java | 6 +-
.../RewriteQueryUsingAggregateIndexCtx.java | 6 +-
.../LBPartitionProcFactory.java | 6 +-
.../ListBucketingPruner.java | 6 +-
.../pcr/PartitionConditionRemover.java | 8 +-
.../ql/optimizer/pcr/PcrExprProcFactory.java | 6 +-
.../hive/ql/optimizer/pcr/PcrOpProcFactory.java | 8 +-
.../optimizer/physical/CrossProductCheck.java | 8 +-
.../physical/GenSparkSkewJoinProcessor.java | 6 +-
.../hive/ql/optimizer/physical/LlapDecider.java | 8 +-
.../physical/LocalMapJoinProcFactory.java | 6 +-
.../ql/optimizer/physical/MemoryDecider.java | 6 +-
.../physical/MetadataOnlyOptimizer.java | 6 +-
.../optimizer/physical/NullScanOptimizer.java | 6 +-
.../physical/NullScanTaskDispatcher.java | 8 +-
.../ql/optimizer/physical/SerializeFilter.java | 6 +-
.../hive/ql/optimizer/physical/Vectorizer.java | 6 +-
.../physical/index/IndexWhereProcCtx.java | 6 +-
.../physical/index/IndexWhereProcessor.java | 6 +-
.../ppr/PartitionExpressionForMetastore.java | 6 +-
.../hive/ql/optimizer/ppr/PartitionPruner.java | 6 +-
.../spark/CombineEquivalentWorkResolver.java | 6 +-
.../spark/SetSparkReducerParallelism.java | 6 +-
.../optimizer/spark/SparkMapJoinOptimizer.java | 6 +-
.../spark/SparkReduceSinkMapJoinProc.java | 6 +-
.../stats/annotation/StatsRulesProcFactory.java | 10 +-
.../hive/ql/parse/AppMasterEventProcessor.java | 6 +-
.../hive/ql/parse/BaseSemanticAnalyzer.java | 13 +-
.../hive/ql/parse/ColumnAccessAnalyzer.java | 6 +-
.../ql/parse/ColumnStatsSemanticAnalyzer.java | 8 +-
.../hive/ql/parse/DDLSemanticAnalyzer.java | 6 +-
.../apache/hadoop/hive/ql/parse/EximUtil.java | 6 +-
.../hadoop/hive/ql/parse/FileSinkProcessor.java | 8 +-
.../hive/ql/parse/FunctionSemanticAnalyzer.java | 10 +-
.../hadoop/hive/ql/parse/GenTezUtils.java | 6 +-
.../apache/hadoop/hive/ql/parse/GenTezWork.java | 10 +-
.../apache/hadoop/hive/ql/parse/HiveParser.g | 5 -
.../hive/ql/parse/ImportSemanticAnalyzer.java | 4 +
.../hadoop/hive/ql/parse/InputSignature.java | 6 +-
.../hive/ql/parse/MacroSemanticAnalyzer.java | 8 +-
.../hadoop/hive/ql/parse/MapReduceCompiler.java | 6 +-
.../hive/ql/parse/MetaDataExportListener.java | 6 +-
.../hadoop/hive/ql/parse/PTFTranslator.java | 6 +-
.../hadoop/hive/ql/parse/ParseDriver.java | 6 +-
.../hive/ql/parse/ProcessAnalyzeTable.java | 6 +-
.../org/apache/hadoop/hive/ql/parse/QB.java | 6 +-
.../org/apache/hadoop/hive/ql/parse/QBExpr.java | 6 +-
.../apache/hadoop/hive/ql/parse/QBMetaData.java | 6 +-
.../hadoop/hive/ql/parse/QBParseInfo.java | 15 +-
.../hadoop/hive/ql/parse/RowResolver.java | 6 +-
.../hadoop/hive/ql/parse/SemanticAnalyzer.java | 22 +-
.../hive/ql/parse/TableAccessAnalyzer.java | 6 +-
.../hadoop/hive/ql/parse/TaskCompiler.java | 6 +-
.../hadoop/hive/ql/parse/TezCompiler.java | 6 +-
.../hadoop/hive/ql/parse/TypeCheckCtx.java | 8 +-
.../hive/ql/parse/TypeCheckProcFactory.java | 6 +-
.../hadoop/hive/ql/parse/UnionProcessor.java | 6 +-
.../hive/ql/parse/spark/GenSparkUtils.java | 6 +-
.../hive/ql/parse/spark/GenSparkWork.java | 6 +-
.../hive/ql/parse/spark/SparkCompiler.java | 6 +-
.../ql/parse/spark/SparkFileSinkProcessor.java | 8 +-
.../SparkPartitionPruningSinkOperator.java | 6 +-
.../parse/spark/SparkProcessAnalyzeTable.java | 6 +-
.../apache/hadoop/hive/ql/plan/BaseWork.java | 10 +-
.../ql/plan/ConditionalResolverCommonJoin.java | 6 +-
.../hadoop/hive/ql/plan/CreateTableDesc.java | 8 +-
.../hive/ql/plan/ExprNodeGenericFuncDesc.java | 8 +-
.../org/apache/hadoop/hive/ql/plan/MapWork.java | 6 +-
.../org/apache/hadoop/hive/ql/plan/PTFDesc.java | 6 +-
.../apache/hadoop/hive/ql/plan/PlanUtils.java | 6 +-
.../hadoop/hive/ql/plan/ReduceSinkDesc.java | 6 +-
.../apache/hadoop/hive/ql/plan/ReduceWork.java | 6 +-
.../org/apache/hadoop/hive/ql/plan/TezWork.java | 6 +-
.../hadoop/hive/ql/ppd/ExprWalkerInfo.java | 6 +-
.../hive/ql/ppd/ExprWalkerProcFactory.java | 6 +-
.../hadoop/hive/ql/ppd/OpProcFactory.java | 6 +-
.../hadoop/hive/ql/ppd/PredicatePushDown.java | 6 +-
.../hive/ql/ppd/SyntheticJoinPredicate.java | 6 +-
.../ql/processors/AddResourceProcessor.java | 6 +-
.../ql/processors/CommandProcessorFactory.java | 6 +-
.../hadoop/hive/ql/processors/CommandUtil.java | 6 +-
.../hive/ql/processors/CompileProcessor.java | 6 +-
.../hive/ql/processors/CryptoProcessor.java | 6 +-
.../ql/processors/DeleteResourceProcessor.java | 6 +-
.../hadoop/hive/ql/processors/DfsProcessor.java | 6 +-
.../hive/ql/processors/ReloadProcessor.java | 6 +-
.../hadoop/hive/ql/processors/SetProcessor.java | 12 +-
.../AuthorizationPreEventListener.java | 6 +-
.../HiveAuthorizationProviderBase.java | 6 +-
.../StorageBasedAuthorizationProvider.java | 6 +-
.../AuthorizationMetaStoreFilterHook.java | 10 +-
.../sqlstd/DummyHiveAuthorizationValidator.java | 6 +-
.../plugin/sqlstd/Operation2Privilege.java | 12 +-
.../plugin/sqlstd/SQLAuthorizationUtils.java | 6 +-
.../sqlstd/SQLStdHiveAccessController.java | 6 +-
.../SQLStdHiveAuthorizationValidator.java | 6 +-
.../hive/ql/session/DependencyResolver.java | 8 +-
.../hadoop/hive/ql/session/OperationLog.java | 12 +-
.../hadoop/hive/ql/session/SessionState.java | 20 +-
.../hive/ql/stats/CounterStatsAggregator.java | 6 +-
.../ql/stats/CounterStatsAggregatorSpark.java | 6 +-
.../ql/stats/CounterStatsAggregatorTez.java | 6 +-
.../hive/ql/stats/CounterStatsPublisher.java | 6 +-
.../hadoop/hive/ql/stats/StatsFactory.java | 6 +-
.../apache/hadoop/hive/ql/stats/StatsUtils.java | 6 +-
.../hive/ql/stats/fs/FSStatsAggregator.java | 10 +-
.../hive/ql/stats/fs/FSStatsPublisher.java | 12 +-
.../hive/ql/txn/AcidHouseKeeperService.java | 10 +-
.../hadoop/hive/ql/txn/compactor/Cleaner.java | 6 +-
.../hive/ql/txn/compactor/CompactorMR.java | 6 +-
.../hive/ql/txn/compactor/CompactorThread.java | 6 +-
.../hadoop/hive/ql/txn/compactor/Initiator.java | 9 +-
.../hadoop/hive/ql/txn/compactor/Worker.java | 8 +-
.../org/apache/hadoop/hive/ql/udf/UDFE.java | 6 +-
.../org/apache/hadoop/hive/ql/udf/UDFPI.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFAverage.java | 6 +-
.../ql/udf/generic/GenericUDAFComputeStats.java | 22 +-
.../udf/generic/GenericUDAFContextNGrams.java | 6 +-
.../ql/udf/generic/GenericUDAFEWAHBitmap.java | 6 +-
.../ql/udf/generic/GenericUDAFFirstValue.java | 6 +-
.../generic/GenericUDAFHistogramNumeric.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFLag.java | 6 +-
.../ql/udf/generic/GenericUDAFLastValue.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFLead.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFLeadLag.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFMax.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFMin.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFNTile.java | 6 +-
.../ql/udf/generic/GenericUDAFPercentRank.java | 6 +-
.../generic/GenericUDAFPercentileApprox.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFRank.java | 6 +-
.../ql/udf/generic/GenericUDAFRowNumber.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFSum.java | 6 +-
.../ql/udf/generic/GenericUDAFVariance.java | 6 +-
.../hive/ql/udf/generic/GenericUDAFnGrams.java | 6 +-
.../udf/generic/GenericUDFFromUtcTimestamp.java | 6 +-
.../hive/ql/udf/generic/GenericUDFRegExp.java | 8 +-
.../ql/udf/generic/GenericUDFTimestamp.java | 4 +-
.../hive/ql/udf/generic/GenericUDFToChar.java | 6 +-
.../ql/udf/generic/GenericUDFToVarchar.java | 6 +-
.../ql/udf/generic/GenericUDFUnixTimeStamp.java | 6 +-
.../ql/udf/generic/GenericUDTFJSONTuple.java | 6 +-
.../udf/generic/GenericUDTFParseUrlTuple.java | 6 +-
.../hive/ql/udf/generic/NGramEstimator.java | 4 +-
.../udf/generic/NumDistinctValueEstimator.java | 14 +-
.../hive/ql/udf/ptf/WindowingTableFunction.java | 6 +-
.../hive/ql/util/ZooKeeperHiveHelper.java | 6 +-
.../hadoop/hive/ql/exec/TestExecDriver.java | 6 +-
.../hive/ql/exec/TestFileSinkOperator.java | 6 +-
.../hadoop/hive/ql/exec/TestUtilities.java | 6 +-
.../TestMapJoinMemoryExhaustionHandler.java | 6 +-
.../session/TestSparkSessionManagerImpl.java | 6 +-
.../hive/ql/exec/tez/TestTezSessionPool.java | 6 +-
.../exec/vector/TestVectorizationContext.java | 6 +-
.../apache/hadoop/hive/ql/io/TestRCFile.java | 6 +-
.../hive/ql/io/TestSymlinkTextInputFormat.java | 8 +-
.../hadoop/hive/ql/io/orc/TestFileDump.java | 50 -
.../hive/ql/io/orc/TestOrcRawRecordMerger.java | 6 +-
.../hive/ql/lockmgr/TestDbTxnManager.java | 13 +-
.../hive/ql/lockmgr/TestDummyTxnManager.java | 10 +-
.../hadoop/hive/ql/log/TestLog4j2Appenders.java | 2 +-
.../parse/TestUpdateDeleteSemanticAnalyzer.java | 6 +-
.../hive/ql/processors/TestSetProcessor.java | 54 +
.../hive/ql/session/TestSessionState.java | 6 +-
.../hive/ql/txn/compactor/CompactorTest.java | 6 +-
.../hive/ql/txn/compactor/TestCleaner.java | 6 +-
.../hive/ql/txn/compactor/TestInitiator.java | 6 +-
.../hive/ql/txn/compactor/TestWorker.java | 6 +-
.../clientnegative/authorization_import.q | 39 +
.../clientpositive/cbo_rp_unionDistinct_2.q | 128 ++
.../test/queries/clientpositive/insert_into1.q | 10 +-
.../test/queries/clientpositive/insert_into2.q | 8 +
.../test/queries/clientpositive/selectindate.q | 9 +
ql/src/test/resources/orc-file-dump.json | 187 +-
ql/src/test/resources/orc-file-has-null.out | 80 +-
.../clientnegative/authorization_import.q.out | 48 +
.../authorization_uri_import.q.out | 29 +
.../clientpositive/bucket_map_join_1.q.out | 4 -
.../clientpositive/bucket_map_join_2.q.out | 4 -
.../clientpositive/cbo_rp_unionDistinct_2.q.out | 545 ++++++
.../encryption_insert_partition_dynamic.q.out | 4 -
.../encryption_join_unencrypted_tbl.q.out | 4 -
.../clientpositive/exim_00_nonpart_empty.q.out | 2 +
.../clientpositive/exim_01_nonpart.q.out | 2 +
.../clientpositive/exim_02_00_part_empty.q.out | 2 +
.../results/clientpositive/exim_02_part.q.out | 2 +
.../clientpositive/exim_04_all_part.q.out | 2 +
.../clientpositive/exim_04_evolved_parts.q.out | 2 +
.../clientpositive/exim_05_some_part.q.out | 2 +
.../clientpositive/exim_06_one_part.q.out | 2 +
.../clientpositive/exim_08_nonpart_rename.q.out | 2 +
.../exim_10_external_managed.q.out | 2 +
.../exim_11_managed_external.q.out | 2 +
.../exim_12_external_location.q.out | 2 +
.../exim_13_managed_location.q.out | 2 +
.../clientpositive/exim_18_part_external.q.out | 2 +
.../exim_19_00_part_external_location.q.out | 2 +
.../exim_19_part_external_location.q.out | 2 +
.../exim_20_part_managed_location.q.out | 2 +
.../exim_24_import_nonexist_authsuccess.q.out | 2 +
.../clientpositive/exim_hidden_files.q.out | 2 +
.../clientpositive/import_exported_table.q.out | 3 +
.../results/clientpositive/insert_into1.q.out | 151 ++
.../results/clientpositive/insert_into2.q.out | 69 +
.../clientpositive/repl_2_exim_basic.q.out | 4 +
.../results/clientpositive/selectindate.q.out | 70 +
.../spark/bucket_map_join_1.q.out | 8 -
.../spark/bucket_map_join_2.q.out | 8 -
.../spark/import_exported_table.q.out | 3 +
.../clientpositive/spark/insert_into1.q.out | 116 ++
.../clientpositive/spark/insert_into2.q.out | 75 +
.../results/clientpositive/spark/stats3.q.out | 2 -
ql/src/test/results/clientpositive/stats3.q.out | 2 -
.../clientpositive/tez/insert_into1.q.out | 120 ++
.../clientpositive/tez/insert_into2.q.out | 75 +
serde/pom.xml | 95 +-
.../hive/serde2/AbstractEncodingAwareSerDe.java | 6 +-
.../hive/serde2/ColumnProjectionUtils.java | 7 +-
.../hadoop/hive/serde2/DelimitedJSONSerDe.java | 6 +-
.../serde2/MetadataTypedColumnsetSerDe.java | 8 +-
.../apache/hadoop/hive/serde2/OpenCSVSerde.java | 6 +-
.../apache/hadoop/hive/serde2/RegexSerDe.java | 6 +-
.../apache/hadoop/hive/serde2/SerDeUtils.java | 9 +-
.../hive/serde2/avro/AvroDeserializer.java | 6 +-
.../serde2/avro/AvroLazyObjectInspector.java | 8 +-
.../hadoop/hive/serde2/avro/AvroSerDe.java | 6 +-
.../hadoop/hive/serde2/avro/AvroSerdeUtils.java | 6 +-
.../hadoop/hive/serde2/avro/AvroSerializer.java | 4 +-
.../hadoop/hive/serde2/avro/InstanceCache.java | 6 +-
.../binarysortable/BinarySortableSerDe.java | 6 +-
.../fast/BinarySortableDeserializeRead.java | 8 +-
.../fast/BinarySortableSerializeWrite.java | 8 +-
.../hive/serde2/columnar/ColumnarSerDe.java | 8 +-
.../hive/serde2/columnar/ColumnarStruct.java | 6 +-
.../hive/serde2/dynamic_type/DynamicSerDe.java | 6 +-
.../hadoop/hive/serde2/io/DateWritable.java | 1 +
.../serde2/io/HiveIntervalDayTimeWritable.java | 6 +-
.../io/HiveIntervalYearMonthWritable.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyBinary.java | 8 +-
.../hadoop/hive/serde2/lazy/LazyDate.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyDouble.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyFloat.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyHiveChar.java | 6 +-
.../hive/serde2/lazy/LazyHiveDecimal.java | 6 +-
.../hive/serde2/lazy/LazyHiveVarchar.java | 6 +-
.../apache/hadoop/hive/serde2/lazy/LazyMap.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyPrimitive.java | 6 +-
.../hive/serde2/lazy/LazySerDeParameters.java | 6 +-
.../hive/serde2/lazy/LazySimpleSerDe.java | 5 -
.../hadoop/hive/serde2/lazy/LazyStruct.java | 6 +-
.../hadoop/hive/serde2/lazy/LazyTimestamp.java | 10 +-
.../lazy/fast/LazySimpleDeserializeRead.java | 144 +-
.../lazy/fast/LazySimpleSerializeWrite.java | 8 +-
.../LazyListObjectInspector.java | 6 +-
.../objectinspector/LazyMapObjectInspector.java | 6 +-
.../LazyUnionObjectInspector.java | 8 +-
.../hive/serde2/lazybinary/LazyBinaryDate.java | 6 +-
.../LazyBinaryHiveIntervalDayTime.java | 6 +-
.../LazyBinaryHiveIntervalYearMonth.java | 6 +-
.../hive/serde2/lazybinary/LazyBinaryMap.java | 6 +-
.../hive/serde2/lazybinary/LazyBinarySerDe.java | 6 +-
.../serde2/lazybinary/LazyBinaryStruct.java | 6 +-
.../serde2/lazybinary/LazyBinaryTimestamp.java | 6 +-
.../hive/serde2/lazybinary/LazyBinaryUnion.java | 6 +-
.../hive/serde2/lazybinary/LazyBinaryUtils.java | 2 +-
.../fast/LazyBinaryDeserializeRead.java | 6 +-
.../fast/LazyBinarySerializeWrite.java | 6 +-
.../objectinspector/ObjectInspectorUtils.java | 6 +-
.../StandardStructObjectInspector.java | 8 +-
.../PrimitiveObjectInspectorUtils.java | 6 +-
.../WritableHiveVarcharObjectInspector.java | 6 +-
.../serde2/thrift/TBinarySortableProtocol.java | 6 +-
.../serde2/thrift/TCTLSeparatedProtocol.java | 6 +-
.../hive/serde2/avro/TestTypeInfoToSchema.java | 7 +-
service/pom.xml | 50 +-
.../apache/hive/service/AbstractService.java | 6 +-
.../apache/hive/service/CompositeService.java | 6 +-
.../org/apache/hive/service/CookieSigner.java | 6 +-
.../apache/hive/service/ServiceOperations.java | 6 +-
.../org/apache/hive/service/ServiceUtils.java | 25 +
.../apache/hive/service/auth/HttpAuthUtils.java | 6 +-
.../auth/LdapAuthenticationProviderImpl.java | 6 +-
.../org/apache/hive/service/cli/CLIService.java | 8 +-
.../cli/operation/HiveCommandOperation.java | 10 +-
.../cli/operation/LogDivertAppender.java | 7 +-
.../hive/service/cli/operation/Operation.java | 6 +-
.../service/cli/operation/OperationManager.java | 9 +-
.../service/cli/session/HiveSessionImpl.java | 12 +-
.../cli/session/HiveSessionImplwithUGI.java | 6 +-
.../service/cli/session/SessionManager.java | 6 +-
.../thrift/RetryingThriftCLIServiceClient.java | 6 +-
.../cli/thrift/ThriftBinaryCLIService.java | 2 +-
.../service/cli/thrift/ThriftCLIService.java | 6 +-
.../cli/thrift/ThriftHttpCLIService.java | 3 +-
.../service/cli/thrift/ThriftHttpServlet.java | 6 +-
.../apache/hive/service/server/HiveServer2.java | 17 +-
.../server/ThreadWithGarbageCleanup.java | 6 +-
.../apache/hive/service/cli/CLIServiceTest.java | 6 +-
shims/0.20S/pom.xml | 63 -
.../hadoop/hive/shims/Hadoop20SShims.java | 734 --------
.../apache/hadoop/hive/shims/Jetty20SShims.java | 53 -
.../apache/hadoop/mapred/WebHCatJTShim20S.java | 123 --
shims/0.23/pom.xml | 31 +-
.../apache/hadoop/mapred/WebHCatJTShim23.java | 6 +-
shims/aggregator/pom.xml | 6 -
shims/common/pom.xml | 20 +-
.../org/apache/hadoop/fs/DefaultFileAccess.java | 6 +-
.../apache/hadoop/hive/shims/HadoopShims.java | 18 +-
.../hadoop/hive/shims/HadoopShimsSecure.java | 6 +-
.../apache/hadoop/hive/shims/ShimLoader.java | 17 +-
.../hive/thrift/HadoopThriftAuthBridge.java | 17 +-
shims/pom.xml | 1 -
shims/scheduler/pom.xml | 19 +-
.../hadoop/hive/schshim/FairSchedulerShim.java | 6 +-
.../hive/spark/client/SparkClientUtilities.java | 6 +-
.../hive/spark/counter/SparkCounters.java | 6 +-
storage-api/pom.xml | 31 +-
.../hadoop/hive/common/io/DiskRangeList.java | 6 +-
.../hive/ql/io/sarg/SearchArgumentImpl.java | 5 -
.../hive/serde2/io/HiveDecimalWritable.java | 4 -
testutils/ptest2/pom.xml | 5 -
.../ptest2/src/main/resources/batch-exec.vm | 2 +
894 files changed, 10411 insertions(+), 9709 deletions(-)
----------------------------------------------------------------------