HIVE-11568 : merge master into branch (Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/c528294b Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/c528294b Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/c528294b Branch: refs/heads/hbase-metastore Commit: c528294bc99c8ba05dd0a3c3f39cc06fb27b9473 Parents: 0fa45e4 e8b2c60 Author: Sergey Shelukhin <ser...@apache.org> Authored: Fri Aug 14 15:58:43 2015 -0700 Committer: Sergey Shelukhin <ser...@apache.org> Committed: Fri Aug 14 15:58:43 2015 -0700 ---------------------------------------------------------------------- accumulo-handler/pom.xml | 4 - .../apache/hadoop/hive/ant/GenVectorCode.java | 105 + .../src/main/resources/beeline-log4j.properties | 24 - beeline/src/main/resources/beeline-log4j2.xml | 40 + bin/ext/beeline.sh | 2 +- bin/hive | 3 + .../hadoop/hive/cli/TestOptionsProcessor.java | 1 - common/pom.xml | 27 +- .../apache/hadoop/hive/common/JavaUtils.java | 11 +- .../org/apache/hadoop/hive/common/LogUtils.java | 18 +- .../hadoop/hive/common/ValidReadTxnList.java | 2 +- .../hadoop/hive/common/type/HiveDecimal.java | 306 - .../org/apache/hadoop/hive/conf/HiveConf.java | 27 +- common/src/main/resources/hive-log4j.properties | 88 - common/src/main/resources/hive-log4j2.xml | 111 + .../hadoop/hive/conf/TestHiveLogging.java | 8 +- .../resources/hive-exec-log4j-test.properties | 59 - .../test/resources/hive-exec-log4j2-test.xml | 86 + .../test/resources/hive-log4j-test.properties | 71 - common/src/test/resources/hive-log4j2-test.xml | 95 + data/conf/hive-log4j-old.properties | 82 - data/conf/hive-log4j.properties | 97 - data/conf/hive-log4j2.xml | 148 + data/conf/spark/log4j.properties | 24 - data/conf/spark/log4j2.xml | 74 + docs/xdocs/language_manual/cli.xml | 2 +- .../test/results/positive/hbase_timestamp.q.out | 8 +- hcatalog/bin/hcat_server.sh | 2 +- hcatalog/bin/templeton.cmd | 4 +- .../mapreduce/DefaultOutputFormatContainer.java | 7 +- ...namicPartitionFileRecordWriterContainer.java | 3 +- .../mapreduce/FileOutputFormatContainer.java | 3 +- .../hive/hcatalog/mapreduce/PartInfo.java | 32 +- .../hive/hcatalog/mapreduce/SpecialCases.java | 8 +- .../mapreduce/TestHCatMultiOutputFormat.java | 6 +- hcatalog/scripts/hcat_server_start.sh | 2 +- .../content/xdocs/configuration.xml | 2 +- .../src/documentation/content/xdocs/install.xml | 2 +- .../deployers/config/hive/hive-log4j.properties | 88 - .../deployers/config/hive/hive-log4j2.xml | 111 + .../templeton/deployers/start_hive_services.sh | 2 +- .../webhcat/svr/src/main/bin/webhcat_server.sh | 4 +- .../src/main/config/webhcat-log4j.properties | 45 - .../svr/src/main/config/webhcat-log4j2.xml | 75 + .../antlr4/org/apache/hive/hplsql/Hplsql.g4 | 164 +- .../main/java/org/apache/hive/hplsql/Conn.java | 6 + .../java/org/apache/hive/hplsql/Converter.java | 41 +- .../main/java/org/apache/hive/hplsql/Exec.java | 65 +- .../java/org/apache/hive/hplsql/Expression.java | 73 +- .../main/java/org/apache/hive/hplsql/Meta.java | 98 + .../main/java/org/apache/hive/hplsql/Query.java | 55 + .../java/org/apache/hive/hplsql/Select.java | 47 +- .../java/org/apache/hive/hplsql/Signal.java | 2 +- .../main/java/org/apache/hive/hplsql/Stmt.java | 97 +- .../main/java/org/apache/hive/hplsql/Var.java | 43 +- .../apache/hive/hplsql/functions/Function.java | 49 +- .../hive/hplsql/functions/FunctionDatetime.java | 14 +- .../hive/hplsql/functions/FunctionMisc.java | 22 +- .../hive/hplsql/functions/FunctionOra.java | 31 +- .../hive/hplsql/functions/FunctionString.java | 46 +- .../org/apache/hive/hplsql/TestHplsqlLocal.java | 5 + .../apache/hive/hplsql/TestHplsqlOffline.java | 76 + .../test/queries/db/create_procedure_mssql.sql | 52 + .../src/test/queries/db/cursor_attributes.sql | 60 + hplsql/src/test/queries/db/map_object.sql | 9 + hplsql/src/test/queries/db/select_into.sql | 17 + .../src/test/queries/db/set_current_schema.sql | 6 + hplsql/src/test/queries/db/sys_refcursor.sql | 65 + hplsql/src/test/queries/db/use.sql | 2 + .../queries/local/exception_divide_by_zero.sql | 11 + .../test/queries/offline/create_table_mssql.sql | 43 + .../test/queries/offline/create_table_ora.sql | 4 + .../results/db/create_procedure_mssql.out.txt | 45 + .../test/results/db/cursor_attributes.out.txt | 33 + hplsql/src/test/results/db/map_object.out.txt | 17 + hplsql/src/test/results/db/select_into.out.txt | 19 + .../test/results/db/set_current_schema.out.txt | 12 + .../src/test/results/db/sys_refcursor.out.txt | 36 + hplsql/src/test/results/db/use.out.txt | 4 + .../test/results/local/create_function.out.txt | 4 +- hplsql/src/test/results/local/declare.out.txt | 4 +- .../local/exception_divide_by_zero.out.txt | 8 + .../results/offline/create_table_mssql.out.txt | 24 + .../results/offline/create_table_ora.out.txt | 4 + .../hive/metastore/TestHiveMetaStore.java | 96 +- .../operation/TestOperationLoggingLayout.java | 136 + itests/pom.xml | 2 +- itests/qtest-spark/pom.xml | 24 + itests/qtest/pom.xml | 28 +- .../test/resources/testconfiguration.properties | 50 +- .../org/apache/hadoop/hive/ql/QTestUtil.java | 62 +- jdbc/pom.xml | 1 + metastore/if/hive_metastore.thrift | 5 + .../gen/thrift/gen-cpp/ThriftHiveMetastore.cpp | 5526 ++- .../gen/thrift/gen-cpp/ThriftHiveMetastore.h | 7970 ++-- .../ThriftHiveMetastore_server.skeleton.cpp | 5 + .../thrift/gen-cpp/hive_metastore_constants.cpp | 2 +- .../thrift/gen-cpp/hive_metastore_constants.h | 2 +- .../gen/thrift/gen-cpp/hive_metastore_types.cpp | 6204 ++- .../gen/thrift/gen-cpp/hive_metastore_types.h | 2666 +- .../hive/metastore/api/AbortTxnRequest.java | 24 +- .../metastore/api/AddDynamicPartitions.java | 69 +- .../metastore/api/AddPartitionsRequest.java | 80 +- .../hive/metastore/api/AddPartitionsResult.java | 48 +- .../hadoop/hive/metastore/api/AggrStats.java | 54 +- .../metastore/api/AlreadyExistsException.java | 24 +- .../metastore/api/BinaryColumnStatsData.java | 40 +- .../metastore/api/BooleanColumnStatsData.java | 40 +- .../hive/metastore/api/CheckLockRequest.java | 24 +- .../hive/metastore/api/ColumnStatistics.java | 54 +- .../metastore/api/ColumnStatisticsData.java | 20 +- .../metastore/api/ColumnStatisticsDesc.java | 58 +- .../hive/metastore/api/ColumnStatisticsObj.java | 40 +- .../hive/metastore/api/CommitTxnRequest.java | 24 +- .../hive/metastore/api/CompactionRequest.java | 62 +- .../hive/metastore/api/CompactionType.java | 2 +- .../api/ConfigValSecurityException.java | 24 +- .../api/CurrentNotificationEventId.java | 24 +- .../hadoop/hive/metastore/api/Database.java | 115 +- .../apache/hadoop/hive/metastore/api/Date.java | 24 +- .../hive/metastore/api/DateColumnStatsData.java | 50 +- .../hadoop/hive/metastore/api/Decimal.java | 41 +- .../metastore/api/DecimalColumnStatsData.java | 50 +- .../metastore/api/DoubleColumnStatsData.java | 50 +- .../hive/metastore/api/DropPartitionsExpr.java | 43 +- .../metastore/api/DropPartitionsRequest.java | 82 +- .../metastore/api/DropPartitionsResult.java | 48 +- .../hive/metastore/api/EnvironmentContext.java | 61 +- .../hive/metastore/api/EventRequestType.java | 2 +- .../hadoop/hive/metastore/api/FieldSchema.java | 58 +- .../hive/metastore/api/FireEventRequest.java | 79 +- .../metastore/api/FireEventRequestData.java | 20 +- .../hive/metastore/api/FireEventResponse.java | 16 +- .../hadoop/hive/metastore/api/Function.java | 110 +- .../hadoop/hive/metastore/api/FunctionType.java | 2 +- .../metastore/api/GetAllFunctionsResponse.java | 447 + .../metastore/api/GetOpenTxnsInfoResponse.java | 54 +- .../hive/metastore/api/GetOpenTxnsResponse.java | 53 +- .../api/GetPrincipalsInRoleRequest.java | 24 +- .../api/GetPrincipalsInRoleResponse.java | 46 +- .../api/GetRoleGrantsForPrincipalRequest.java | 36 +- .../api/GetRoleGrantsForPrincipalResponse.java | 46 +- .../api/GrantRevokePrivilegeRequest.java | 46 +- .../api/GrantRevokePrivilegeResponse.java | 26 +- .../metastore/api/GrantRevokeRoleRequest.java | 86 +- .../metastore/api/GrantRevokeRoleResponse.java | 26 +- .../hive/metastore/api/GrantRevokeType.java | 2 +- .../hive/metastore/api/HeartbeatRequest.java | 34 +- .../metastore/api/HeartbeatTxnRangeRequest.java | 32 +- .../api/HeartbeatTxnRangeResponse.java | 74 +- .../hive/metastore/api/HiveObjectPrivilege.java | 52 +- .../hive/metastore/api/HiveObjectRef.java | 81 +- .../hive/metastore/api/HiveObjectType.java | 2 +- .../apache/hadoop/hive/metastore/api/Index.java | 133 +- .../api/IndexAlreadyExistsException.java | 24 +- .../metastore/api/InsertEventRequestData.java | 45 +- .../metastore/api/InvalidInputException.java | 24 +- .../metastore/api/InvalidObjectException.java | 24 +- .../api/InvalidOperationException.java | 24 +- .../api/InvalidPartitionException.java | 24 +- .../hive/metastore/api/LockComponent.java | 66 +- .../hadoop/hive/metastore/api/LockLevel.java | 2 +- .../hadoop/hive/metastore/api/LockRequest.java | 72 +- .../hadoop/hive/metastore/api/LockResponse.java | 36 +- .../hadoop/hive/metastore/api/LockState.java | 2 +- .../hadoop/hive/metastore/api/LockType.java | 2 +- .../hive/metastore/api/LongColumnStatsData.java | 50 +- .../hive/metastore/api/MetaException.java | 24 +- .../hive/metastore/api/NoSuchLockException.java | 24 +- .../metastore/api/NoSuchObjectException.java | 24 +- .../hive/metastore/api/NoSuchTxnException.java | 24 +- .../hive/metastore/api/NotificationEvent.java | 66 +- .../metastore/api/NotificationEventRequest.java | 34 +- .../api/NotificationEventResponse.java | 46 +- .../hive/metastore/api/OpenTxnRequest.java | 40 +- .../hive/metastore/api/OpenTxnsResponse.java | 45 +- .../apache/hadoop/hive/metastore/api/Order.java | 32 +- .../hadoop/hive/metastore/api/Partition.java | 156 +- .../hive/metastore/api/PartitionEventType.java | 2 +- .../api/PartitionListComposingSpec.java | 46 +- .../hive/metastore/api/PartitionSpec.java | 58 +- .../api/PartitionSpecWithSharedSD.java | 54 +- .../hive/metastore/api/PartitionWithoutSD.java | 124 +- .../metastore/api/PartitionsByExprRequest.java | 67 +- .../metastore/api/PartitionsByExprResult.java | 54 +- .../metastore/api/PartitionsStatsRequest.java | 90 +- .../metastore/api/PartitionsStatsResult.java | 72 +- .../metastore/api/PrincipalPrivilegeSet.java | 184 +- .../hive/metastore/api/PrincipalType.java | 2 +- .../hadoop/hive/metastore/api/PrivilegeBag.java | 46 +- .../hive/metastore/api/PrivilegeGrantInfo.java | 60 +- .../hive/metastore/api/RequestPartsSpec.java | 56 +- .../hadoop/hive/metastore/api/ResourceType.java | 2 +- .../hadoop/hive/metastore/api/ResourceUri.java | 36 +- .../apache/hadoop/hive/metastore/api/Role.java | 40 +- .../hive/metastore/api/RolePrincipalGrant.java | 80 +- .../hadoop/hive/metastore/api/Schema.java | 91 +- .../hadoop/hive/metastore/api/SerDeInfo.java | 93 +- .../api/SetPartitionsStatsRequest.java | 46 +- .../hive/metastore/api/ShowCompactRequest.java | 16 +- .../hive/metastore/api/ShowCompactResponse.java | 46 +- .../api/ShowCompactResponseElement.java | 86 +- .../hive/metastore/api/ShowLocksRequest.java | 16 +- .../hive/metastore/api/ShowLocksResponse.java | 46 +- .../metastore/api/ShowLocksResponseElement.java | 114 +- .../hadoop/hive/metastore/api/SkewedInfo.java | 147 +- .../hive/metastore/api/StorageDescriptor.java | 242 +- .../metastore/api/StringColumnStatsData.java | 48 +- .../apache/hadoop/hive/metastore/api/Table.java | 189 +- .../hive/metastore/api/TableStatsRequest.java | 61 +- .../hive/metastore/api/TableStatsResult.java | 46 +- .../hive/metastore/api/ThriftHiveMetastore.java | 33504 +++++++++++------ .../hive/metastore/api/TxnAbortedException.java | 24 +- .../hadoop/hive/metastore/api/TxnInfo.java | 52 +- .../hive/metastore/api/TxnOpenException.java | 24 +- .../hadoop/hive/metastore/api/TxnState.java | 2 +- .../apache/hadoop/hive/metastore/api/Type.java | 72 +- .../hive/metastore/api/UnknownDBException.java | 24 +- .../api/UnknownPartitionException.java | 24 +- .../metastore/api/UnknownTableException.java | 24 +- .../hive/metastore/api/UnlockRequest.java | 24 +- .../hadoop/hive/metastore/api/Version.java | 32 +- .../metastore/api/hive_metastoreConstants.java | 7 +- .../gen-php/metastore/ThriftHiveMetastore.php | 4599 ++- .../src/gen/thrift/gen-php/metastore/Types.php | 1184 +- .../hive_metastore/ThriftHiveMetastore-remote | 620 +- .../hive_metastore/ThriftHiveMetastore.py | 4624 ++- .../thrift/gen-py/hive_metastore/constants.py | 2 +- .../gen/thrift/gen-py/hive_metastore/ttypes.py | 856 +- .../thrift/gen-rb/hive_metastore_constants.rb | 2 +- .../gen/thrift/gen-rb/hive_metastore_types.rb | 18 +- .../gen/thrift/gen-rb/thrift_hive_metastore.rb | 62 +- .../hadoop/hive/metastore/HiveMetaStore.java | 34 +- .../hive/metastore/HiveMetaStoreClient.java | 7 + .../hadoop/hive/metastore/IMetaStoreClient.java | 4 + .../hadoop/hive/metastore/ObjectStore.java | 35 +- .../apache/hadoop/hive/metastore/RawStore.java | 7 + .../hadoop/hive/metastore/hbase/HBaseStore.java | 16 + .../hadoop/hive/metastore/txn/TxnHandler.java | 32 +- .../metastore/txn/ValidCompactorTxnList.java | 2 +- .../DummyRawStoreControlledCommit.java | 7 + .../DummyRawStoreForJdoConnection.java | 6 + .../metastore/txn/TestCompactionTxnHandler.java | 40 +- .../hive/metastore/txn/TestTxnHandler.java | 66 +- packaging/src/main/assembly/bin.xml | 17 +- pom.xml | 52 +- ql/if/queryplan.thrift | 1 + ql/pom.xml | 24 +- .../gen/thrift/gen-cpp/queryplan_constants.cpp | 2 +- ql/src/gen/thrift/gen-cpp/queryplan_constants.h | 2 +- ql/src/gen/thrift/gen-cpp/queryplan_types.cpp | 796 +- ql/src/gen/thrift/gen-cpp/queryplan_types.h | 294 +- .../hadoop/hive/ql/plan/api/Adjacency.java | 65 +- .../hadoop/hive/ql/plan/api/AdjacencyType.java | 2 +- .../apache/hadoop/hive/ql/plan/api/Graph.java | 87 +- .../hadoop/hive/ql/plan/api/NodeType.java | 2 +- .../hadoop/hive/ql/plan/api/Operator.java | 142 +- .../hadoop/hive/ql/plan/api/OperatorType.java | 7 +- .../apache/hadoop/hive/ql/plan/api/Query.java | 176 +- .../hadoop/hive/ql/plan/api/QueryPlan.java | 62 +- .../apache/hadoop/hive/ql/plan/api/Stage.java | 172 +- .../hadoop/hive/ql/plan/api/StageType.java | 2 +- .../apache/hadoop/hive/ql/plan/api/Task.java | 182 +- .../hadoop/hive/ql/plan/api/TaskType.java | 2 +- ql/src/gen/thrift/gen-php/Types.php | 119 +- ql/src/gen/thrift/gen-py/queryplan/constants.py | 2 +- ql/src/gen/thrift/gen-py/queryplan/ttypes.py | 87 +- ql/src/gen/thrift/gen-rb/queryplan_constants.rb | 2 +- ql/src/gen/thrift/gen-rb/queryplan_types.rb | 7 +- ...tringGroupColumnCompareStringGroupColumn.txt | 112 +- ...gGroupColumnCompareStringGroupScalarBase.txt | 12 +- ...gGroupScalarCompareStringGroupColumnBase.txt | 12 +- ...tringGroupColumnCompareStringGroupColumn.txt | 112 +- ...gGroupColumnCompareStringGroupScalarBase.txt | 12 +- ...gGroupScalarCompareStringGroupColumnBase.txt | 12 +- .../java/org/apache/hadoop/hive/ql/Context.java | 1 - .../java/org/apache/hadoop/hive/ql/Driver.java | 209 +- .../org/apache/hadoop/hive/ql/ErrorMsg.java | 13 +- .../org/apache/hadoop/hive/ql/QueryPlan.java | 18 +- .../hadoop/hive/ql/exec/FileSinkOperator.java | 2 +- .../hadoop/hive/ql/exec/FunctionRegistry.java | 3 +- .../hive/ql/exec/HashTableSinkOperator.java | 6 +- .../apache/hadoop/hive/ql/exec/MoveTask.java | 4 +- .../apache/hadoop/hive/ql/exec/Operator.java | 25 - .../hadoop/hive/ql/exec/OperatorFactory.java | 11 + .../ql/exec/SparkHashTableSinkOperator.java | 17 +- .../apache/hadoop/hive/ql/exec/Utilities.java | 36 +- .../hadoop/hive/ql/exec/mr/ExecDriver.java | 29 +- .../hive/ql/exec/mr/HadoopJobExecHelper.java | 20 +- .../persistence/HybridHashTableContainer.java | 6 + .../persistence/MapJoinTableContainerSerDe.java | 63 +- .../hive/ql/exec/spark/HashTableLoader.java | 26 +- .../ql/exec/spark/HiveSparkClientFactory.java | 10 +- .../hive/ql/exec/spark/KryoSerializer.java | 4 + .../ql/exec/spark/RemoteHiveSparkClient.java | 57 +- .../exec/spark/SparkDynamicPartitionPruner.java | 268 + .../hadoop/hive/ql/exec/spark/SparkPlan.java | 3 - .../hive/ql/exec/spark/SparkPlanGenerator.java | 15 +- .../hadoop/hive/ql/exec/spark/SparkTask.java | 1 + .../hive/ql/exec/spark/SparkUtilities.java | 56 + .../spark/status/impl/LocalSparkJobStatus.java | 2 +- .../spark/status/impl/RemoteSparkJobStatus.java | 2 +- .../hive/ql/exec/vector/BytesColumnVector.java | 347 - .../hive/ql/exec/vector/ColumnVector.java | 178 - .../ql/exec/vector/DecimalColumnVector.java | 125 - .../hive/ql/exec/vector/DoubleColumnVector.java | 161 - .../hive/ql/exec/vector/LongColumnVector.java | 205 - .../VectorSparkHashTableSinkOperator.java | 104 + ...VectorSparkPartitionPruningSinkOperator.java | 99 + .../ql/exec/vector/VectorizationContext.java | 51 +- .../hive/ql/exec/vector/VectorizedRowBatch.java | 186 - .../BRoundWithNumDigitsDoubleToDouble.java | 42 + .../ql/exec/vector/expressions/DecimalUtil.java | 18 + .../vector/expressions/FilterExprAndExpr.java | 8 +- .../vector/expressions/FilterExprOrExpr.java | 140 +- ...FuncBRoundWithNumDigitsDecimalToDecimal.java | 40 + .../FuncRoundWithNumDigitsDecimalToDecimal.java | 14 +- .../ql/exec/vector/expressions/MathExpr.java | 22 + .../ql/exec/vector/expressions/StringExpr.java | 51 + .../hadoop/hive/ql/hooks/LineageInfo.java | 9 +- .../hadoop/hive/ql/hooks/LineageLogger.java | 44 +- .../hive/ql/hooks/PostExecOrcFileDump.java | 120 + .../ql/hooks/PostExecTezSummaryPrinter.java | 72 + .../hive/ql/io/CombineHiveInputFormat.java | 98 +- .../hadoop/hive/ql/io/HiveInputFormat.java | 46 +- .../apache/hadoop/hive/ql/io/orc/FileDump.java | 4 + .../apache/hadoop/hive/ql/io/orc/OrcConf.java | 129 +- .../apache/hadoop/hive/ql/io/orc/OrcFile.java | 141 +- .../hadoop/hive/ql/io/orc/OrcInputFormat.java | 38 +- .../hadoop/hive/ql/io/orc/OrcOutputFormat.java | 67 +- .../apache/hadoop/hive/ql/io/orc/OrcSerde.java | 6 +- .../apache/hadoop/hive/ql/io/orc/Reader.java | 7 + .../hadoop/hive/ql/io/orc/ReaderImpl.java | 5 +- .../hadoop/hive/ql/io/orc/RecordReaderImpl.java | 48 +- .../hive/ql/io/orc/TreeReaderFactory.java | 12 +- .../parquet/read/DataWritableReadSupport.java | 10 +- .../read/ParquetFilterPredicateConverter.java | 148 + .../read/ParquetRecordReaderWrapper.java | 125 +- .../ql/io/rcfile/stats/PartialScanTask.java | 20 +- .../hive/ql/io/sarg/ConvertAstToSearchArg.java | 439 + .../hive/ql/io/sarg/SearchArgumentFactory.java | 56 - .../hive/ql/io/sarg/SearchArgumentImpl.java | 1027 - .../hadoop/hive/ql/lib/PreOrderOnceWalker.java | 44 + .../hadoop/hive/ql/lockmgr/DbLockManager.java | 12 +- .../hadoop/hive/ql/lockmgr/DbTxnManager.java | 71 +- .../hadoop/hive/ql/lockmgr/DummyTxnManager.java | 8 + .../hadoop/hive/ql/lockmgr/HiveTxnManager.java | 21 + .../hive/ql/lockmgr/HiveTxnManagerImpl.java | 10 + .../hadoop/hive/ql/lockmgr/LockException.java | 8 +- .../hadoop/hive/ql/log/HiveEventCounter.java | 135 + .../apache/hadoop/hive/ql/log/NullAppender.java | 63 + .../ql/log/PidDailyRollingFileAppender.java | 33 - .../hive/ql/log/PidFilePatternConverter.java | 62 + .../apache/hadoop/hive/ql/metadata/Hive.java | 107 +- .../hadoop/hive/ql/metadata/HiveException.java | 3 + .../hadoop/hive/ql/metadata/Partition.java | 2 +- .../hadoop/hive/ql/metadata/TableIterable.java | 104 + .../hadoop/hive/ql/optimizer/ColumnPruner.java | 4 + .../hive/ql/optimizer/ColumnPrunerProcCtx.java | 95 +- .../ql/optimizer/ColumnPrunerProcFactory.java | 42 +- .../optimizer/ConstantPropagateProcFactory.java | 123 +- .../DynamicPartitionPruningOptimization.java | 44 +- .../hive/ql/optimizer/GenMapRedUtils.java | 20 +- .../hive/ql/optimizer/GroupByOptimizer.java | 58 +- .../ql/optimizer/OperatorComparatorFactory.java | 552 + .../hadoop/hive/ql/optimizer/Optimizer.java | 8 +- .../hive/ql/optimizer/PointLookupOptimizer.java | 280 + .../hive/ql/optimizer/SimpleFetchOptimizer.java | 5 +- .../SparkRemoveDynamicPruningBySize.java | 73 + .../calcite/rules/HiveJoinToMultiJoinRule.java | 82 +- .../calcite/translator/ExprNodeConverter.java | 21 +- .../calcite/translator/HiveOpConverter.java | 46 +- .../translator/PlanModifierForASTConv.java | 2 +- .../translator/PlanModifierForReturnPath.java | 6 +- .../correlation/AbstractCorrelationProcCtx.java | 7 + .../correlation/CorrelationUtilities.java | 11 +- .../correlation/ReduceSinkDeDuplication.java | 6 +- .../ql/optimizer/lineage/ExprProcFactory.java | 9 +- .../hive/ql/optimizer/lineage/LineageCtx.java | 34 +- .../ql/optimizer/lineage/OpProcFactory.java | 10 +- .../ql/optimizer/pcr/PcrExprProcFactory.java | 154 +- .../physical/GenSparkSkewJoinProcessor.java | 14 +- .../hive/ql/optimizer/physical/Vectorizer.java | 24 + .../hive/ql/optimizer/ppr/OpProcFactory.java | 3 +- .../hive/ql/optimizer/ppr/PartitionPruner.java | 69 +- .../spark/CombineEquivalentWorkResolver.java | 292 + .../spark/SparkPartitionPruningSinkDesc.java | 100 + .../spark/SparkReduceSinkMapJoinProc.java | 2 +- .../stats/annotation/StatsRulesProcFactory.java | 49 +- .../apache/hadoop/hive/ql/parse/ASTNode.java | 139 +- .../hive/ql/parse/BaseSemanticAnalyzer.java | 13 + .../hadoop/hive/ql/parse/CalcitePlanner.java | 45 +- .../org/apache/hadoop/hive/ql/parse/HiveLexer.g | 11 + .../apache/hadoop/hive/ql/parse/HiveParser.g | 70 + .../hadoop/hive/ql/parse/IdentifiersParser.g | 29 +- .../apache/hadoop/hive/ql/parse/ParseUtils.java | 2 +- .../hadoop/hive/ql/parse/SemanticAnalyzer.java | 74 +- .../hive/ql/parse/SemanticAnalyzerFactory.java | 12 + .../hive/ql/parse/TypeCheckProcFactory.java | 42 +- .../ql/parse/spark/GenSparkProcContext.java | 14 +- .../hive/ql/parse/spark/GenSparkUtils.java | 111 +- .../parse/spark/OptimizeSparkProcContext.java | 16 +- .../hive/ql/parse/spark/SparkCompiler.java | 180 +- .../SparkPartitionPruningSinkOperator.java | 142 + .../hive/ql/parse/spark/SplitOpTreeForDPP.java | 151 + .../hive/ql/plan/ExprNodeConstantDesc.java | 29 +- .../apache/hadoop/hive/ql/plan/FilterDesc.java | 14 +- .../hadoop/hive/ql/plan/HiveOperation.java | 32 +- .../hadoop/hive/ql/plan/JoinCondDesc.java | 14 + .../apache/hadoop/hive/ql/plan/JoinDesc.java | 4 + .../org/apache/hadoop/hive/ql/plan/MapWork.java | 20 +- .../hadoop/hive/ql/plan/PartitionDesc.java | 39 +- .../apache/hadoop/hive/ql/plan/PlanUtils.java | 9 +- .../hadoop/hive/ql/plan/ReduceSinkDesc.java | 1 + .../hive/ql/plan/SparkHashTableSinkDesc.java | 11 + .../hadoop/hive/ql/plan/TableScanDesc.java | 6 +- .../hive/ql/ppd/SyntheticJoinPredicate.java | 14 +- .../ql/processors/CommandProcessorResponse.java | 21 +- .../hadoop/hive/ql/processors/HiveCommand.java | 3 + .../hadoop/hive/ql/processors/SetProcessor.java | 4 + .../authorization/plugin/HiveOperationType.java | 5 + .../plugin/sqlstd/Operation2Privilege.java | 11 + .../hadoop/hive/ql/session/SessionState.java | 44 +- .../apache/hadoop/hive/ql/stats/StatsUtils.java | 54 +- .../hive/ql/udf/generic/GenericUDAFStd.java | 2 + .../ql/udf/generic/GenericUDAFVariance.java | 2 + .../hive/ql/udf/generic/GenericUDFBRound.java | 68 + .../hive/ql/udf/generic/GenericUDFBridge.java | 8 +- .../hive/ql/udf/generic/GenericUDFIn.java | 14 +- .../hive/ql/udf/generic/GenericUDFOPAnd.java | 59 +- .../hive/ql/udf/generic/GenericUDFOPOr.java | 59 +- .../hive/ql/udf/generic/GenericUDFRound.java | 41 +- .../hive/ql/udf/generic/GenericUDFStruct.java | 25 +- .../hadoop/hive/ql/udf/generic/RoundUtils.java | 14 + .../main/resources/hive-exec-log4j.properties | 77 - ql/src/main/resources/hive-exec-log4j2.xml | 110 + .../apache/hadoop/hive/ql/TestTxnCommands.java | 473 + .../exec/vector/TestVectorizationContext.java | 93 + .../exec/vector/TestVectorizedRowBatchCtx.java | 6 +- .../TestVectorLogicalExpressions.java | 282 + .../hive/ql/io/orc/TestInputOutputFormat.java | 118 +- .../hadoop/hive/ql/io/orc/TestOrcFile.java | 11 +- .../hive/ql/io/orc/TestRecordReaderImpl.java | 63 +- .../hive/ql/io/orc/TestVectorizedORCReader.java | 75 +- .../parquet/TestParquetRecordReaderWrapper.java | 155 + .../read/TestParquetFilterPredicate.java | 51 + .../ql/io/sarg/TestConvertAstToSearchArg.java | 2856 ++ .../hive/ql/io/sarg/TestSearchArgumentImpl.java | 2891 +- .../hive/ql/lockmgr/TestDbTxnManager.java | 55 +- .../hive/ql/lockmgr/TestDbTxnManager2.java | 2 +- .../hadoop/hive/ql/log/TestLog4j2Appenders.java | 95 + .../hadoop/hive/ql/metadata/StringAppender.java | 128 + .../hadoop/hive/ql/metadata/TestHive.java | 50 +- .../positive/TestTransactionStatement.java | 102 + .../hive/ql/session/TestSessionState.java | 2 +- .../ql/udf/generic/TestGenericUDFBRound.java | 202 + .../queries/clientnegative/ctas_noemptyfolder.q | 10 + .../clientnegative/mismatch_columns_insertion.q | 4 + .../annotate_stats_deep_filters.q | 67 + .../clientpositive/authorization_1_sql_std.q | 4 + .../clientpositive/cast_tinyint_to_double.q | 7 + ql/src/test/queries/clientpositive/cbo_rp_gby.q | 24 + .../queries/clientpositive/cbo_rp_gby_empty.q | 30 + .../test/queries/clientpositive/cbo_rp_insert.q | 17 + .../test/queries/clientpositive/cbo_rp_join.q | 65 + .../test/queries/clientpositive/cbo_rp_limit.q | 16 + .../queries/clientpositive/cbo_rp_semijoin.q | 17 + .../clientpositive/cbo_rp_simple_select.q | 56 + .../test/queries/clientpositive/cbo_rp_stats.q | 10 + .../queries/clientpositive/cbo_rp_subq_exists.q | 67 + .../queries/clientpositive/cbo_rp_subq_in.q | 56 + .../queries/clientpositive/cbo_rp_subq_not_in.q | 81 + .../queries/clientpositive/cbo_rp_udf_udaf.q | 20 + .../test/queries/clientpositive/cbo_rp_union.q | 14 + .../test/queries/clientpositive/cbo_rp_views.q | 46 + .../queries/clientpositive/cbo_rp_windowing.q | 21 + .../queries/clientpositive/compustat_avro.q | 8 +- .../test/queries/clientpositive/create_like.q | 12 + .../queries/clientpositive/dynamic_rdd_cache.q | 111 + .../queries/clientpositive/flatten_and_or.q | 17 + ql/src/test/queries/clientpositive/groupby5.q | 2 + .../clientpositive/insertoverwrite_bucket.q | 28 + ql/src/test/queries/clientpositive/lineage3.q | 22 +- .../clientpositive/load_dyn_part14_win.q | 18 +- .../queries/clientpositive/macro_duplicate.q | 10 + .../test/queries/clientpositive/orc_file_dump.q | 57 + .../test/queries/clientpositive/orc_ppd_basic.q | 177 + .../clientpositive/parquet_predicate_pushdown.q | 9 + .../spark_dynamic_partition_pruning.q | 180 + .../spark_dynamic_partition_pruning_2.q | 118 + ...spark_vectorized_dynamic_partition_pruning.q | 192 + .../test/queries/clientpositive/stats_ppr_all.q | 24 + ql/src/test/queries/clientpositive/structin.q | 17 + ql/src/test/queries/clientpositive/udf_bround.q | 44 + .../clientpositive/udf_from_utc_timestamp.q | 30 +- .../queries/clientpositive/udf_percentile.q | 2 + .../clientpositive/udf_to_utc_timestamp.q | 30 +- .../clientpositive/unionall_unbalancedppd.q | 192 + .../test/queries/clientpositive/vector_acid3.q | 17 + .../test/queries/clientpositive/vector_bround.q | 14 + .../clientnegative/ctas_noemptyfolder.q.out | 19 + .../clientnegative/exchange_partition.q.out | 2 +- .../mismatch_columns_insertion.q.out | 9 + .../groupby2_map_skew_multi_distinct.q.out | 9 + .../spark/groupby2_multi_distinct.q.out | 9 + .../groupby3_map_skew_multi_distinct.q.out | 9 + .../spark/groupby3_multi_distinct.q.out | 9 + .../spark/groupby_grouping_sets7.q.out | 9 + .../alter_partition_coltype.q.out | 12 +- .../annotate_stats_deep_filters.q.out | 244 + .../clientpositive/annotate_stats_filter.q.out | 8 +- .../authorization_1_sql_std.q.out | 11 + .../clientpositive/cast_tinyint_to_double.q.out | 38 + .../results/clientpositive/cbo_rp_gby.q.out | 124 + .../clientpositive/cbo_rp_gby_empty.q.out | 77 + .../results/clientpositive/cbo_rp_insert.q.out | 89 + .../results/clientpositive/cbo_rp_join.q.out | 15028 ++++++++ .../results/clientpositive/cbo_rp_limit.q.out | 90 + .../clientpositive/cbo_rp_semijoin.q.out | 440 + .../clientpositive/cbo_rp_simple_select.q.out | 755 + .../results/clientpositive/cbo_rp_stats.q.out | 14 + .../clientpositive/cbo_rp_subq_exists.q.out | 297 + .../results/clientpositive/cbo_rp_subq_in.q.out | 151 + .../clientpositive/cbo_rp_subq_not_in.q.out | 365 + .../clientpositive/cbo_rp_udf_udaf.q.out | 125 + .../results/clientpositive/cbo_rp_union.q.out | 920 + .../results/clientpositive/cbo_rp_views.q.out | 237 + .../clientpositive/cbo_rp_windowing.q.out | 293 + .../results/clientpositive/compustat_avro.q.out | 8 +- .../clientpositive/convert_enum_to_string.q.out | 9 +- .../results/clientpositive/create_like.q.out | 66 + .../clientpositive/dynamic_rdd_cache.q.out | 1428 + .../clientpositive/exchange_partition.q.out | 4 +- .../clientpositive/exchange_partition2.q.out | 4 +- .../clientpositive/exchange_partition3.q.out | 4 +- .../results/clientpositive/flatten_and_or.q.out | 66 + .../test/results/clientpositive/groupby5.q.out | 8 +- .../groupby_multi_single_reducer2.q.out | 2 +- .../groupby_multi_single_reducer3.q.out | 12 +- .../clientpositive/groupby_sort_1_23.q.out | 56 +- .../clientpositive/groupby_sort_skew_1_23.q.out | 56 +- .../clientpositive/infer_const_type.q.out | 7 +- .../clientpositive/input_testxpath4.q.out | 2 +- .../clientpositive/insertoverwrite_bucket.q.out | 104 + .../join_cond_pushdown_unqual4.q.out | 2 +- .../test/results/clientpositive/lineage3.q.out | 65 +- .../clientpositive/load_dyn_part14_win.q.out | 167 +- .../clientpositive/macro_duplicate.q.out | 56 + .../results/clientpositive/multi_insert.q.out | 8 +- .../clientpositive/multi_insert_gby.q.out | 2 +- .../multi_insert_lateral_view.q.out | 4 +- ...i_insert_move_tasks_share_dependencies.q.out | 360 +- .../test/results/clientpositive/null_cast.q.out | 6 +- .../results/clientpositive/orc_file_dump.q.out | 447 + .../clientpositive/orc_predicate_pushdown.q.out | 36 +- .../parquet_predicate_pushdown.q.out | 47 + ql/src/test/results/clientpositive/pcr.q.out | 12 +- .../results/clientpositive/ppd_gby_join.q.out | 4 +- .../test/results/clientpositive/ppd_join.q.out | 4 +- .../test/results/clientpositive/ppd_join2.q.out | 22 +- .../test/results/clientpositive/ppd_join3.q.out | 52 +- .../clientpositive/ppd_outer_join4.q.out | 2 +- .../results/clientpositive/ppd_transform.q.out | 12 +- ql/src/test/results/clientpositive/ptf.q.out | 27 +- .../results/clientpositive/show_functions.q.out | 1 + .../clientpositive/spark/auto_join18.q.out | 24 +- .../clientpositive/spark/auto_join30.q.out | 51 +- .../clientpositive/spark/auto_join32.q.out | 24 +- .../spark/auto_smb_mapjoin_14.q.out | 30 +- .../spark/auto_sortmerge_join_10.q.out | 23 +- .../results/clientpositive/spark/bucket2.q.out | 3 - .../results/clientpositive/spark/bucket3.q.out | 3 - .../results/clientpositive/spark/bucket4.q.out | 3 - .../spark/column_access_stats.q.out | 4 - .../spark/dynamic_rdd_cache.q.out | 1073 + .../clientpositive/spark/groupby10.q.out | 32 +- .../clientpositive/spark/groupby1_map.q.out | 412 + .../spark/groupby1_map_nomap.q.out | 408 + .../spark/groupby1_map_skew.q.out | 427 + .../clientpositive/spark/groupby1_noskew.q.out | 406 + .../clientpositive/spark/groupby2_map.q.out | 118 + .../spark/groupby2_map_multi_distinct.q.out | 232 + .../spark/groupby2_map_skew.q.out | 129 + .../clientpositive/spark/groupby2_noskew.q.out | 111 + .../spark/groupby2_noskew_multi_distinct.q.out | 114 + .../clientpositive/spark/groupby4_map.q.out | 93 + .../spark/groupby4_map_skew.q.out | 93 + .../clientpositive/spark/groupby4_noskew.q.out | 104 + .../results/clientpositive/spark/groupby5.q.out | 433 + .../clientpositive/spark/groupby5_map.q.out | 95 + .../spark/groupby5_map_skew.q.out | 95 + .../clientpositive/spark/groupby5_noskew.q.out | 418 + .../results/clientpositive/spark/groupby6.q.out | 113 + .../clientpositive/spark/groupby6_map.q.out | 109 + .../spark/groupby6_map_skew.q.out | 122 + .../clientpositive/spark/groupby6_noskew.q.out | 104 + .../clientpositive/spark/groupby7_map.q.out | 23 +- .../spark/groupby7_map_skew.q.out | 38 +- .../clientpositive/spark/groupby7_noskew.q.out | 17 +- .../groupby7_noskew_multi_single_reducer.q.out | 18 +- .../results/clientpositive/spark/groupby8.q.out | 62 +- .../spark/groupby8_map_skew.q.out | 37 +- .../spark/groupby_grouping_id2.q.out | 230 + .../spark/groupby_multi_single_reducer2.q.out | 2 +- .../spark/groupby_multi_single_reducer3.q.out | 12 +- .../clientpositive/spark/groupby_position.q.out | 37 +- .../spark/groupby_ppr_multi_distinct.q.out | 346 + .../spark/groupby_resolution.q.out | 796 + .../spark/groupby_sort_1_23.q.out | 90 +- .../spark/groupby_sort_skew_1_23.q.out | 90 +- .../clientpositive/spark/insert_into3.q.out | 33 +- .../results/clientpositive/spark/join18.q.out | 24 +- .../results/clientpositive/spark/join22.q.out | 19 +- .../spark/join_cond_pushdown_unqual4.q.out | 2 +- .../spark/limit_partition_metadataonly.q.out | 2 - .../clientpositive/spark/limit_pushdown.q.out | 31 +- .../spark/list_bucket_dml_2.q.java1.7.out | 3 - .../clientpositive/spark/load_dyn_part14.q.out | 30 +- .../clientpositive/spark/multi_insert.q.out | 8 +- .../clientpositive/spark/multi_insert_gby.q.out | 2 +- .../spark/multi_insert_lateral_view.q.out | 4 +- ...i_insert_move_tasks_share_dependencies.q.out | 536 +- .../clientpositive/spark/nullgroup.q.out | 265 + .../clientpositive/spark/nullgroup2.q.out | 300 + .../clientpositive/spark/nullgroup4.q.out | 292 + .../spark/nullgroup4_multi_distinct.q.out | 133 + .../spark/optimize_nullscan.q.out | 3 - .../test/results/clientpositive/spark/pcr.q.out | 18 +- .../clientpositive/spark/ppd_gby_join.q.out | 4 +- .../results/clientpositive/spark/ppd_join.q.out | 4 +- .../clientpositive/spark/ppd_join2.q.out | 22 +- .../clientpositive/spark/ppd_join3.q.out | 52 +- .../clientpositive/spark/ppd_outer_join4.q.out | 2 +- .../clientpositive/spark/ppd_transform.q.out | 12 +- .../test/results/clientpositive/spark/ptf.q.out | 17 +- .../results/clientpositive/spark/sample3.q.out | 3 - .../results/clientpositive/spark/sample9.q.out | 3 - .../clientpositive/spark/skewjoinopt11.q.out | 60 +- .../clientpositive/spark/skewjoinopt9.q.out | 20 +- .../clientpositive/spark/smb_mapjoin_11.q.out | 6 - .../spark/spark_dynamic_partition_pruning.q.out | 5573 +++ .../spark_dynamic_partition_pruning_2.q.out | 1015 + ...k_vectorized_dynamic_partition_pruning.q.out | 5822 +++ .../clientpositive/spark/temp_table_gb1.q.out | 67 + .../clientpositive/spark/udaf_collect_set.q.out | 212 + .../clientpositive/spark/udf_example_add.q.out | 3 - .../clientpositive/spark/udf_in_file.q.out | 3 - .../results/clientpositive/spark/udf_max.q.out | 62 + .../results/clientpositive/spark/udf_min.q.out | 62 + .../clientpositive/spark/udf_percentile.q.out | 450 + .../results/clientpositive/spark/union10.q.out | 36 +- .../results/clientpositive/spark/union11.q.out | 38 +- .../results/clientpositive/spark/union15.q.out | 23 +- .../results/clientpositive/spark/union16.q.out | 450 +- .../results/clientpositive/spark/union2.q.out | 36 +- .../results/clientpositive/spark/union20.q.out | 18 +- .../results/clientpositive/spark/union25.q.out | 21 +- .../results/clientpositive/spark/union28.q.out | 21 +- .../results/clientpositive/spark/union3.q.out | 45 +- .../results/clientpositive/spark/union30.q.out | 21 +- .../results/clientpositive/spark/union4.q.out | 18 +- .../results/clientpositive/spark/union5.q.out | 20 +- .../results/clientpositive/spark/union9.q.out | 54 +- .../clientpositive/spark/union_remove_1.q.out | 23 +- .../clientpositive/spark/union_remove_15.q.out | 23 +- .../clientpositive/spark/union_remove_16.q.out | 23 +- .../clientpositive/spark/union_remove_18.q.out | 23 +- .../clientpositive/spark/union_remove_19.q.out | 75 +- .../clientpositive/spark/union_remove_20.q.out | 23 +- .../clientpositive/spark/union_remove_21.q.out | 21 +- .../clientpositive/spark/union_remove_22.q.out | 46 +- .../clientpositive/spark/union_remove_24.q.out | 23 +- .../clientpositive/spark/union_remove_25.q.out | 59 +- .../clientpositive/spark/union_remove_4.q.out | 23 +- .../clientpositive/spark/union_remove_6.q.out | 23 +- .../spark/union_remove_6_subq.q.out | 84 +- .../clientpositive/spark/union_remove_7.q.out | 23 +- .../clientpositive/spark/union_top_level.q.out | 59 +- .../clientpositive/spark/union_view.q.out | 33 +- .../spark/vector_count_distinct.q.out | 31 +- .../spark/vector_decimal_mapjoin.q.out | 1 + .../clientpositive/spark/vector_elt.q.out | 7 - .../spark/vector_left_outer_join.q.out | 2 + .../spark/vector_mapjoin_reduce.q.out | 1 + .../spark/vector_string_concat.q.out | 3 - .../clientpositive/spark/vectorization_0.q.out | 2 +- .../clientpositive/spark/vectorization_13.q.out | 4 +- .../clientpositive/spark/vectorization_15.q.out | 2 +- .../clientpositive/spark/vectorization_17.q.out | 12 +- .../spark/vectorization_decimal_date.q.out | 4 - .../spark/vectorization_div0.q.out | 3 - .../spark/vectorization_short_regress.q.out | 40 +- .../clientpositive/spark/vectorized_case.q.out | 5 +- .../spark/vectorized_mapjoin.q.out | 1 + .../spark/vectorized_math_funcs.q.out | 3 - .../spark/vectorized_nested_mapjoin.q.out | 2 + .../clientpositive/spark/vectorized_ptf.q.out | 21 +- .../spark/vectorized_string_funcs.q.out | 3 - .../results/clientpositive/stats_ppr_all.q.out | 284 + .../test/results/clientpositive/structin.q.out | 66 + .../clientpositive/tez/explainuser_1.q.out | 71 +- .../clientpositive/tez/orc_ppd_basic.q.out | 701 + .../test/results/clientpositive/tez/ptf.q.out | 15 +- .../results/clientpositive/tez/union2.q.out | 28 +- .../results/clientpositive/tez/union9.q.out | 40 +- .../clientpositive/tez/vector_acid3.q.out | 31 + .../tez/vector_mr_diff_schema_alias.q.out | 2 +- .../tez/vector_null_projection.q.out | 4 + .../clientpositive/tez/vectorization_0.q.out | 2 +- .../clientpositive/tez/vectorization_13.q.out | 4 +- .../clientpositive/tez/vectorization_15.q.out | 2 +- .../clientpositive/tez/vectorization_17.q.out | 12 +- .../clientpositive/tez/vectorization_7.q.out | 4 +- .../clientpositive/tez/vectorization_8.q.out | 4 +- .../tez/vectorization_short_regress.q.out | 40 +- .../clientpositive/tez/vectorized_case.q.out | 2 +- .../clientpositive/tez/vectorized_ptf.q.out | 19 +- .../results/clientpositive/udf_bround.q.out | 119 + .../clientpositive/udf_from_utc_timestamp.q.out | 66 +- .../results/clientpositive/udf_inline.q.out | 8 +- ql/src/test/results/clientpositive/udf_or.q.out | 4 +- .../results/clientpositive/udf_percentile.q.out | 104 +- .../results/clientpositive/udf_struct.q.out | 2 +- .../clientpositive/udf_to_utc_timestamp.q.out | 66 +- .../test/results/clientpositive/udf_union.q.out | 2 +- .../test/results/clientpositive/union16.q.out | 354 +- ql/src/test/results/clientpositive/union2.q.out | 32 +- ql/src/test/results/clientpositive/union9.q.out | 46 +- .../clientpositive/union_remove_6_subq.q.out | 34 +- .../results/clientpositive/union_view.q.out | 24 + .../clientpositive/unionall_unbalancedppd.q.out | 653 + .../results/clientpositive/vector_acid3.q.out | 31 + .../results/clientpositive/vector_bround.q.out | 86 + .../vector_mr_diff_schema_alias.q.out | 2 +- .../clientpositive/vector_null_projection.q.out | 4 + .../clientpositive/vectorization_0.q.out | 2 +- .../clientpositive/vectorization_13.q.out | 4 +- .../clientpositive/vectorization_15.q.out | 2 +- .../clientpositive/vectorization_17.q.out | 12 +- .../clientpositive/vectorization_7.q.out | 4 +- .../clientpositive/vectorization_8.q.out | 4 +- .../vectorization_short_regress.q.out | 40 +- .../clientpositive/vectorized_case.q.out | 9 +- .../results/clientpositive/vectorized_ptf.q.out | 67 +- .../gen/thrift/gen-cpp/complex_constants.cpp | 2 +- .../src/gen/thrift/gen-cpp/complex_constants.h | 2 +- serde/src/gen/thrift/gen-cpp/complex_types.cpp | 442 +- serde/src/gen/thrift/gen-cpp/complex_types.h | 174 +- .../gen/thrift/gen-cpp/megastruct_constants.cpp | 2 +- .../gen/thrift/gen-cpp/megastruct_constants.h | 2 +- .../src/gen/thrift/gen-cpp/megastruct_types.cpp | 585 +- serde/src/gen/thrift/gen-cpp/megastruct_types.h | 175 +- .../src/gen/thrift/gen-cpp/serde_constants.cpp | 2 +- serde/src/gen/thrift/gen-cpp/serde_constants.h | 2 +- serde/src/gen/thrift/gen-cpp/serde_types.cpp | 5 +- serde/src/gen/thrift/gen-cpp/serde_types.h | 5 +- .../gen/thrift/gen-cpp/testthrift_constants.cpp | 2 +- .../gen/thrift/gen-cpp/testthrift_constants.h | 2 +- .../src/gen/thrift/gen-cpp/testthrift_types.cpp | 95 +- serde/src/gen/thrift/gen-cpp/testthrift_types.h | 45 +- .../hadoop/hive/serde/serdeConstants.java | 7 +- .../hadoop/hive/serde/test/InnerStruct.java | 24 +- .../hadoop/hive/serde/test/ThriftTestObj.java | 62 +- .../hadoop/hive/serde2/thrift/test/Complex.java | 279 +- .../hive/serde2/thrift/test/IntString.java | 40 +- .../hive/serde2/thrift/test/MegaStruct.java | 521 +- .../hive/serde2/thrift/test/MiniStruct.java | 38 +- .../hadoop/hive/serde2/thrift/test/MyEnum.java | 2 +- .../hive/serde2/thrift/test/PropValueUnion.java | 60 +- .../hive/serde2/thrift/test/SetIntString.java | 54 +- serde/src/gen/thrift/gen-php/Types.php | 15 +- .../org/apache/hadoop/hive/serde/Types.php | 373 +- .../src/gen/thrift/gen-py/complex/constants.py | 2 +- serde/src/gen/thrift/gen-py/complex/ttypes.py | 50 +- .../gen/thrift/gen-py/megastruct/constants.py | 2 +- .../src/gen/thrift/gen-py/megastruct/ttypes.py | 44 +- .../org_apache_hadoop_hive_serde/constants.py | 2 +- .../org_apache_hadoop_hive_serde/ttypes.py | 2 +- .../gen/thrift/gen-py/testthrift/constants.py | 2 +- .../src/gen/thrift/gen-py/testthrift/ttypes.py | 14 +- .../src/gen/thrift/gen-rb/complex_constants.rb | 2 +- serde/src/gen/thrift/gen-rb/complex_types.rb | 2 +- .../gen/thrift/gen-rb/megastruct_constants.rb | 2 +- serde/src/gen/thrift/gen-rb/megastruct_types.rb | 2 +- serde/src/gen/thrift/gen-rb/serde_constants.rb | 2 +- serde/src/gen/thrift/gen-rb/serde_types.rb | 2 +- .../gen/thrift/gen-rb/testthrift_constants.rb | 2 +- serde/src/gen/thrift/gen-rb/testthrift_types.rb | 2 +- .../hadoop/hive/ql/io/sarg/ExpressionTree.java | 157 - .../hadoop/hive/ql/io/sarg/PredicateLeaf.java | 87 - .../hadoop/hive/ql/io/sarg/SearchArgument.java | 278 - .../apache/hadoop/hive/serde2/SerDeUtils.java | 14 +- .../apache/hadoop/hive/serde2/WriteBuffers.java | 2 +- .../hadoop/hive/serde2/avro/InstanceCache.java | 9 +- .../hive/serde2/io/HiveDecimalWritable.java | 185 - .../hive/serde2/lazy/LazyHiveDecimal.java | 3 +- .../lazy/fast/LazySimpleDeserializeRead.java | 16 +- .../lazybinary/LazyBinaryHiveDecimal.java | 2 +- .../hive/serde2/lazybinary/LazyBinarySerDe.java | 26 +- .../fast/LazyBinaryDeserializeRead.java | 6 +- .../fast/LazyBinarySerializeWrite.java | 5 +- .../objectinspector/ObjectInspectorFactory.java | 7 +- .../objectinspector/ObjectInspectorUtils.java | 19 + .../StandardConstantStructObjectInspector.java | 51 + .../hive/serde2/typeinfo/HiveDecimalUtils.java | 35 +- .../hive/serde2/typeinfo/TypeInfoUtils.java | 2 +- .../hive/serde2/avro/TestInstanceCache.java | 40 +- service/src/gen/thrift/gen-cpp/TCLIService.cpp | 458 +- service/src/gen/thrift/gen-cpp/TCLIService.h | 821 +- .../thrift/gen-cpp/TCLIService_constants.cpp | 2 +- .../gen/thrift/gen-cpp/TCLIService_constants.h | 2 +- .../gen/thrift/gen-cpp/TCLIService_types.cpp | 3250 +- .../src/gen/thrift/gen-cpp/TCLIService_types.h | 1482 +- service/src/gen/thrift/gen-cpp/ThriftHive.cpp | 286 +- service/src/gen/thrift/gen-cpp/ThriftHive.h | 389 +- .../thrift/gen-cpp/hive_service_constants.cpp | 2 +- .../gen/thrift/gen-cpp/hive_service_constants.h | 2 +- .../gen/thrift/gen-cpp/hive_service_types.cpp | 110 +- .../src/gen/thrift/gen-cpp/hive_service_types.h | 75 +- .../hadoop/hive/service/HiveClusterStatus.java | 68 +- .../hive/service/HiveServerException.java | 40 +- .../hadoop/hive/service/JobTrackerState.java | 2 +- .../apache/hadoop/hive/service/ThriftHive.java | 914 +- .../service/cli/thrift/TArrayTypeEntry.java | 24 +- .../hive/service/cli/thrift/TBinaryColumn.java | 64 +- .../hive/service/cli/thrift/TBoolColumn.java | 62 +- .../hive/service/cli/thrift/TBoolValue.java | 26 +- .../hive/service/cli/thrift/TByteColumn.java | 62 +- .../hive/service/cli/thrift/TByteValue.java | 26 +- .../hive/service/cli/thrift/TCLIService.java | 1734 +- .../cli/thrift/TCLIServiceConstants.java | 7 +- .../cli/thrift/TCancelDelegationTokenReq.java | 32 +- .../cli/thrift/TCancelDelegationTokenResp.java | 24 +- .../service/cli/thrift/TCancelOperationReq.java | 24 +- .../cli/thrift/TCancelOperationResp.java | 24 +- .../service/cli/thrift/TCloseOperationReq.java | 24 +- .../service/cli/thrift/TCloseOperationResp.java | 24 +- .../service/cli/thrift/TCloseSessionReq.java | 24 +- .../service/cli/thrift/TCloseSessionResp.java | 24 +- .../apache/hive/service/cli/thrift/TColumn.java | 20 +- .../hive/service/cli/thrift/TColumnDesc.java | 50 +- .../hive/service/cli/thrift/TColumnValue.java | 20 +- .../hive/service/cli/thrift/TDoubleColumn.java | 62 +- .../hive/service/cli/thrift/TDoubleValue.java | 26 +- .../cli/thrift/TExecuteStatementReq.java | 87 +- .../cli/thrift/TExecuteStatementResp.java | 34 +- .../service/cli/thrift/TFetchOrientation.java | 2 +- .../service/cli/thrift/TFetchResultsReq.java | 54 +- .../service/cli/thrift/TFetchResultsResp.java | 42 +- .../service/cli/thrift/TGetCatalogsReq.java | 24 +- .../service/cli/thrift/TGetCatalogsResp.java | 34 +- .../hive/service/cli/thrift/TGetColumnsReq.java | 58 +- .../service/cli/thrift/TGetColumnsResp.java | 34 +- .../cli/thrift/TGetDelegationTokenReq.java | 40 +- .../cli/thrift/TGetDelegationTokenResp.java | 34 +- .../service/cli/thrift/TGetFunctionsReq.java | 50 +- .../service/cli/thrift/TGetFunctionsResp.java | 34 +- .../hive/service/cli/thrift/TGetInfoReq.java | 36 +- .../hive/service/cli/thrift/TGetInfoResp.java | 32 +- .../hive/service/cli/thrift/TGetInfoType.java | 2 +- .../hive/service/cli/thrift/TGetInfoValue.java | 20 +- .../cli/thrift/TGetOperationStatusReq.java | 24 +- .../cli/thrift/TGetOperationStatusResp.java | 62 +- .../cli/thrift/TGetResultSetMetadataReq.java | 24 +- .../cli/thrift/TGetResultSetMetadataResp.java | 34 +- .../hive/service/cli/thrift/TGetSchemasReq.java | 42 +- .../service/cli/thrift/TGetSchemasResp.java | 34 +- .../service/cli/thrift/TGetTableTypesReq.java | 24 +- .../service/cli/thrift/TGetTableTypesResp.java | 34 +- .../hive/service/cli/thrift/TGetTablesReq.java | 79 +- .../hive/service/cli/thrift/TGetTablesResp.java | 34 +- .../service/cli/thrift/TGetTypeInfoReq.java | 24 +- .../service/cli/thrift/TGetTypeInfoResp.java | 34 +- .../service/cli/thrift/THandleIdentifier.java | 50 +- .../hive/service/cli/thrift/TI16Column.java | 62 +- .../hive/service/cli/thrift/TI16Value.java | 26 +- .../hive/service/cli/thrift/TI32Column.java | 62 +- .../hive/service/cli/thrift/TI32Value.java | 26 +- .../hive/service/cli/thrift/TI64Column.java | 62 +- .../hive/service/cli/thrift/TI64Value.java | 26 +- .../hive/service/cli/thrift/TMapTypeEntry.java | 32 +- .../service/cli/thrift/TOpenSessionReq.java | 91 +- .../service/cli/thrift/TOpenSessionResp.java | 91 +- .../service/cli/thrift/TOperationHandle.java | 54 +- .../service/cli/thrift/TOperationState.java | 2 +- .../hive/service/cli/thrift/TOperationType.java | 2 +- .../service/cli/thrift/TPrimitiveTypeEntry.java | 38 +- .../service/cli/thrift/TProtocolVersion.java | 2 +- .../cli/thrift/TRenewDelegationTokenReq.java | 32 +- .../cli/thrift/TRenewDelegationTokenResp.java | 24 +- .../apache/hive/service/cli/thrift/TRow.java | 46 +- .../apache/hive/service/cli/thrift/TRowSet.java | 86 +- .../hive/service/cli/thrift/TSessionHandle.java | 24 +- .../apache/hive/service/cli/thrift/TStatus.java | 83 +- .../hive/service/cli/thrift/TStatusCode.java | 2 +- .../hive/service/cli/thrift/TStringColumn.java | 62 +- .../hive/service/cli/thrift/TStringValue.java | 26 +- .../service/cli/thrift/TStructTypeEntry.java | 50 +- .../hive/service/cli/thrift/TTableSchema.java | 46 +- .../hive/service/cli/thrift/TTypeDesc.java | 46 +- .../hive/service/cli/thrift/TTypeEntry.java | 20 +- .../apache/hive/service/cli/thrift/TTypeId.java | 2 +- .../service/cli/thrift/TTypeQualifierValue.java | 20 +- .../service/cli/thrift/TTypeQualifiers.java | 54 +- .../service/cli/thrift/TUnionTypeEntry.java | 50 +- .../cli/thrift/TUserDefinedTypeEntry.java | 24 +- service/src/gen/thrift/gen-php/TCLIService.php | 269 +- service/src/gen/thrift/gen-php/ThriftHive.php | 125 +- service/src/gen/thrift/gen-php/Types.php | 30 +- .../gen-py/TCLIService/TCLIService-remote | 102 +- .../thrift/gen-py/TCLIService/TCLIService.py | 439 +- .../gen/thrift/gen-py/TCLIService/constants.py | 2 +- .../src/gen/thrift/gen-py/TCLIService/ttypes.py | 478 +- .../gen-py/hive_service/ThriftHive-remote | 1021 +- .../thrift/gen-py/hive_service/ThriftHive.py | 266 +- .../gen/thrift/gen-py/hive_service/constants.py | 2 +- .../gen/thrift/gen-py/hive_service/ttypes.py | 19 +- .../gen/thrift/gen-rb/hive_service_constants.rb | 2 +- .../src/gen/thrift/gen-rb/hive_service_types.rb | 2 +- .../src/gen/thrift/gen-rb/t_c_l_i_service.rb | 2 +- .../thrift/gen-rb/t_c_l_i_service_constants.rb | 2 +- .../gen/thrift/gen-rb/t_c_l_i_service_types.rb | 2 +- service/src/gen/thrift/gen-rb/thrift_hive.rb | 2 +- .../hive/service/cli/CLIServiceUtils.java | 7 - .../cli/operation/GetColumnsOperation.java | 10 +- .../cli/operation/GetTablesOperation.java | 7 +- .../cli/operation/LogDivertAppender.java | 223 +- .../service/cli/operation/OperationManager.java | 17 +- .../service/cli/session/SessionManager.java | 42 +- .../session/TestPluggableHiveSessionImpl.java | 55 + shims/common/pom.xml | 17 +- .../hadoop/hive/shims/HiveEventCounter.java | 102 - spark-client/pom.xml | 5 + .../hive/spark/client/SparkClientImpl.java | 20 +- .../hive/spark/client/SparkClientUtilities.java | 13 +- .../hive/spark/client/TestSparkClient.java | 4 +- .../src/test/resources/log4j.properties | 23 - spark-client/src/test/resources/log4j2.xml | 39 + storage-api/pom.xml | 78 + .../hadoop/hive/common/type/HiveDecimal.java | 313 + .../hive/ql/exec/vector/BytesColumnVector.java | 322 + .../hive/ql/exec/vector/ColumnVector.java | 173 + .../ql/exec/vector/DecimalColumnVector.java | 106 + .../hive/ql/exec/vector/DoubleColumnVector.java | 143 + .../hive/ql/exec/vector/LongColumnVector.java | 189 + .../hive/ql/exec/vector/VectorizedRowBatch.java | 186 + .../hadoop/hive/ql/io/sarg/ExpressionTree.java | 156 + .../hadoop/hive/ql/io/sarg/PredicateLeaf.java | 104 + .../hadoop/hive/ql/io/sarg/SearchArgument.java | 287 + .../hive/ql/io/sarg/SearchArgumentFactory.java | 28 + .../hive/ql/io/sarg/SearchArgumentImpl.java | 687 + .../hive/serde2/io/HiveDecimalWritable.java | 174 + testutils/ptest2/pom.xml | 20 + .../ptest2/src/main/resources/log4j.properties | 37 - testutils/ptest2/src/main/resources/log4j2.xml | 79 + 955 files changed, 130154 insertions(+), 43331 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/itests/qtest/pom.xml ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/itests/src/test/resources/testconfiguration.properties ---------------------------------------------------------------------- diff --cc itests/src/test/resources/testconfiguration.properties index eb986db,bed621d..c877f85 --- a/itests/src/test/resources/testconfiguration.properties +++ b/itests/src/test/resources/testconfiguration.properties @@@ -1142,48 -1184,8 +1184,54 @@@ miniSparkOnYarn.query.files=auto_sortme truncate_column_buckets.q,\ uber_reduce.q +miniHbaseMetastore.query.files=join1.q,\ +join2.q,\ +mapjoin1.q,\ +add_part_multiple.q,\ +annotate_stats_join.q,\ +authorization_parts.q,\ +auto_join1.q,\ +bucket1.q,\ +compute_stats_string.q,\ +create_1.q,\ +groupby1.q,\ +groupby12.q,\ +having.q,\ +innerjoin.q,\ +input_part10.q,\ +input20.q,\ +join1.q,\ +join20.q,\ +leftsemijoin.q,\ +mapjoin1.q,\ +multi_insert_gby.q,\ +orc_create.q,\ +orc_merge1.q,\ +show_roles.q,\ +stats0.q,\ +statsfs.q,\ +temp_table.q,\ +union.q,\ +union10.q,\ +alter_partition_change_col,\ +alter1.q,\ +analyze_tbl_part.q,\ +authorization_1.q,\ +columnstats_part_coltype.q,\ +ctas.q,\ +database.q,\ +drop_partition_with_stats.q,\ +drop_table_with_stats.q,\ +inputddl8.q,\ +order2.q,\ +partition_date.q,\ +partition_multilevels.q,\ +show_partitions.q,\ +sort.q,\ +view.q ++ + spark.query.negative.files=groupby2_map_skew_multi_distinct.q,\ + groupby2_multi_distinct.q,\ + groupby3_map_skew_multi_distinct.q,\ + groupby3_multi_distinct.q,\ + groupby_grouping_sets7.q http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/if/hive_metastore.thrift ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp index fbc8400,0354fe1..fcc4f0b --- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp +++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.cpp @@@ -28313,116 -31450,6 +31450,140 @@@ uint32_t ThriftHiveMetastore_fire_liste return xfer; } ++ ++ThriftHiveMetastore_flushCache_args::~ThriftHiveMetastore_flushCache_args() throw() { ++} ++ ++ +uint32_t ThriftHiveMetastore_flushCache_args::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + xfer += iprot->skip(ftype); + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t ThriftHiveMetastore_flushCache_args::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; ++ oprot->incrementRecursionDepth(); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_flushCache_args"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); ++ oprot->decrementRecursionDepth(); + return xfer; +} + ++ ++ThriftHiveMetastore_flushCache_pargs::~ThriftHiveMetastore_flushCache_pargs() throw() { ++} ++ ++ +uint32_t ThriftHiveMetastore_flushCache_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const { + uint32_t xfer = 0; ++ oprot->incrementRecursionDepth(); + xfer += oprot->writeStructBegin("ThriftHiveMetastore_flushCache_pargs"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); ++ oprot->decrementRecursionDepth(); + return xfer; +} + ++ ++ThriftHiveMetastore_flushCache_result::~ThriftHiveMetastore_flushCache_result() throw() { ++} ++ ++ +uint32_t ThriftHiveMetastore_flushCache_result::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + xfer += iprot->skip(ftype); + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + +uint32_t ThriftHiveMetastore_flushCache_result::write(::apache::thrift::protocol::TProtocol* oprot) const { + + uint32_t xfer = 0; + + xfer += oprot->writeStructBegin("ThriftHiveMetastore_flushCache_result"); + + xfer += oprot->writeFieldStop(); + xfer += oprot->writeStructEnd(); + return xfer; +} + ++ ++ThriftHiveMetastore_flushCache_presult::~ThriftHiveMetastore_flushCache_presult() throw() { ++} ++ ++ +uint32_t ThriftHiveMetastore_flushCache_presult::read(::apache::thrift::protocol::TProtocol* iprot) { + + uint32_t xfer = 0; + std::string fname; + ::apache::thrift::protocol::TType ftype; + int16_t fid; + + xfer += iprot->readStructBegin(fname); + + using ::apache::thrift::protocol::TProtocolException; + + + while (true) + { + xfer += iprot->readFieldBegin(fname, ftype, fid); + if (ftype == ::apache::thrift::protocol::T_STOP) { + break; + } + xfer += iprot->skip(ftype); + xfer += iprot->readFieldEnd(); + } + + xfer += iprot->readStructEnd(); + + return xfer; +} + void ThriftHiveMetastoreClient::getMetaConf(std::string& _return, const std::string& key) { send_getMetaConf(key); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h index a534c2e,520c6e3..baa28e3 --- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h +++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h @@@ -17333,82 -18190,9 +18194,99 @@@ class ThriftHiveMetastore_fire_listener uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + friend std::ostream& operator<<(std::ostream& out, const ThriftHiveMetastore_fire_listener_event_presult& obj); }; + +class ThriftHiveMetastore_flushCache_args { + public: + ++ static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; ++ static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; ++ ++ ThriftHiveMetastore_flushCache_args(const ThriftHiveMetastore_flushCache_args&); ++ ThriftHiveMetastore_flushCache_args& operator=(const ThriftHiveMetastore_flushCache_args&); + ThriftHiveMetastore_flushCache_args() { + } + - virtual ~ThriftHiveMetastore_flushCache_args() throw() {} - ++ virtual ~ThriftHiveMetastore_flushCache_args() throw(); + + bool operator == (const ThriftHiveMetastore_flushCache_args & /* rhs */) const + { + return true; + } + bool operator != (const ThriftHiveMetastore_flushCache_args &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ThriftHiveMetastore_flushCache_args & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + ++ friend std::ostream& operator<<(std::ostream& out, const ThriftHiveMetastore_flushCache_args& obj); +}; + + +class ThriftHiveMetastore_flushCache_pargs { + public: + ++ static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; ++ static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + - virtual ~ThriftHiveMetastore_flushCache_pargs() throw() {} + ++ virtual ~ThriftHiveMetastore_flushCache_pargs() throw(); + + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + ++ friend std::ostream& operator<<(std::ostream& out, const ThriftHiveMetastore_flushCache_pargs& obj); +}; + + +class ThriftHiveMetastore_flushCache_result { + public: + ++ static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; ++ static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; ++ ++ ThriftHiveMetastore_flushCache_result(const ThriftHiveMetastore_flushCache_result&); ++ ThriftHiveMetastore_flushCache_result& operator=(const ThriftHiveMetastore_flushCache_result&); + ThriftHiveMetastore_flushCache_result() { + } + - virtual ~ThriftHiveMetastore_flushCache_result() throw() {} - ++ virtual ~ThriftHiveMetastore_flushCache_result() throw(); + + bool operator == (const ThriftHiveMetastore_flushCache_result & /* rhs */) const + { + return true; + } + bool operator != (const ThriftHiveMetastore_flushCache_result &rhs) const { + return !(*this == rhs); + } + + bool operator < (const ThriftHiveMetastore_flushCache_result & ) const; + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const; + ++ friend std::ostream& operator<<(std::ostream& out, const ThriftHiveMetastore_flushCache_result& obj); +}; + + +class ThriftHiveMetastore_flushCache_presult { + public: + ++ static const char* ascii_fingerprint; // = "99914B932BD37A50B983C5E7C90AE93B"; ++ static const uint8_t binary_fingerprint[16]; // = {0x99,0x91,0x4B,0x93,0x2B,0xD3,0x7A,0x50,0xB9,0x83,0xC5,0xE7,0xC9,0x0A,0xE9,0x3B}; + - virtual ~ThriftHiveMetastore_flushCache_presult() throw() {} + ++ virtual ~ThriftHiveMetastore_flushCache_presult() throw(); + + uint32_t read(::apache::thrift::protocol::TProtocol* iprot); + ++ friend std::ostream& operator<<(std::ostream& out, const ThriftHiveMetastore_flushCache_presult& obj); +}; + class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public ::facebook::fb303::FacebookServiceClient { public: ThriftHiveMetastoreClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) : http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java index 5d44585,37e5bf1..ae12142 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AbortTxnRequest.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AbortTxnRequest implements org.apache.thrift.TBase<AbortTxnRequest, AbortTxnRequest._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AbortTxnRequest implements org.apache.thrift.TBase<AbortTxnRequest, AbortTxnRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AbortTxnRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AbortTxnRequest"); private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java index afb2b79,9c78c49..f60521f --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicPartitions, AddDynamicPartitions._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AddDynamicPartitions implements org.apache.thrift.TBase<AddDynamicPartitions, AddDynamicPartitions._Fields>, java.io.Serializable, Cloneable, Comparable<AddDynamicPartitions> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddDynamicPartitions"); private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java index 7bb72ba,fcfaaf3..00a7236 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AddPartitionsRequest implements org.apache.thrift.TBase<AddPartitionsRequest, AddPartitionsRequest._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AddPartitionsRequest implements org.apache.thrift.TBase<AddPartitionsRequest, AddPartitionsRequest._Fields>, java.io.Serializable, Cloneable, Comparable<AddPartitionsRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddPartitionsRequest"); private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("dbName", org.apache.thrift.protocol.TType.STRING, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java index 875e04a,9022019..7150e68 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AddPartitionsResult implements org.apache.thrift.TBase<AddPartitionsResult, AddPartitionsResult._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AddPartitionsResult implements org.apache.thrift.TBase<AddPartitionsResult, AddPartitionsResult._Fields>, java.io.Serializable, Cloneable, Comparable<AddPartitionsResult> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AddPartitionsResult"); private static final org.apache.thrift.protocol.TField PARTITIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("partitions", org.apache.thrift.protocol.TType.LIST, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java index 0e1dbcb,917cec0..bf14ac0 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AggrStats implements org.apache.thrift.TBase<AggrStats, AggrStats._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AggrStats implements org.apache.thrift.TBase<AggrStats, AggrStats._Fields>, java.io.Serializable, Cloneable, Comparable<AggrStats> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AggrStats"); private static final org.apache.thrift.protocol.TField COL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("colStats", org.apache.thrift.protocol.TType.LIST, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java index 2a5e58f,d7a317b..16f2cb7 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AlreadyExistsException.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class AlreadyExistsException extends TException implements org.apache.thrift.TBase<AlreadyExistsException, AlreadyExistsException._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class AlreadyExistsException extends TException implements org.apache.thrift.TBase<AlreadyExistsException, AlreadyExistsException._Fields>, java.io.Serializable, Cloneable, Comparable<AlreadyExistsException> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyExistsException"); private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java index 1516b25,00b312d..7ddb91a --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BinaryColumnStatsData.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class BinaryColumnStatsData implements org.apache.thrift.TBase<BinaryColumnStatsData, BinaryColumnStatsData._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class BinaryColumnStatsData implements org.apache.thrift.TBase<BinaryColumnStatsData, BinaryColumnStatsData._Fields>, java.io.Serializable, Cloneable, Comparable<BinaryColumnStatsData> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BinaryColumnStatsData"); private static final org.apache.thrift.protocol.TField MAX_COL_LEN_FIELD_DESC = new org.apache.thrift.protocol.TField("maxColLen", org.apache.thrift.protocol.TType.I64, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java index 9ef9c0f,a0f3ab8..f98e56b --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/BooleanColumnStatsData.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class BooleanColumnStatsData implements org.apache.thrift.TBase<BooleanColumnStatsData, BooleanColumnStatsData._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class BooleanColumnStatsData implements org.apache.thrift.TBase<BooleanColumnStatsData, BooleanColumnStatsData._Fields>, java.io.Serializable, Cloneable, Comparable<BooleanColumnStatsData> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BooleanColumnStatsData"); private static final org.apache.thrift.protocol.TField NUM_TRUES_FIELD_DESC = new org.apache.thrift.protocol.TField("numTrues", org.apache.thrift.protocol.TType.I64, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CheckLockRequest.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CheckLockRequest.java index ae34203,82e3031..667d12e --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CheckLockRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CheckLockRequest.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class CheckLockRequest implements org.apache.thrift.TBase<CheckLockRequest, CheckLockRequest._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class CheckLockRequest implements org.apache.thrift.TBase<CheckLockRequest, CheckLockRequest._Fields>, java.io.Serializable, Cloneable, Comparable<CheckLockRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CheckLockRequest"); private static final org.apache.thrift.protocol.TField LOCKID_FIELD_DESC = new org.apache.thrift.protocol.TField("lockid", org.apache.thrift.protocol.TType.I64, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java index b34619f,510dace..dd9aeb7 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class ColumnStatistics implements org.apache.thrift.TBase<ColumnStatistics, ColumnStatistics._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class ColumnStatistics implements org.apache.thrift.TBase<ColumnStatistics, ColumnStatistics._Fields>, java.io.Serializable, Cloneable, Comparable<ColumnStatistics> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnStatistics"); private static final org.apache.thrift.protocol.TField STATS_DESC_FIELD_DESC = new org.apache.thrift.protocol.TField("statsDesc", org.apache.thrift.protocol.TType.STRUCT, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java index e951d04,cf967b6..09f925c --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsDesc.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class ColumnStatisticsDesc implements org.apache.thrift.TBase<ColumnStatisticsDesc, ColumnStatisticsDesc._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class ColumnStatisticsDesc implements org.apache.thrift.TBase<ColumnStatisticsDesc, ColumnStatisticsDesc._Fields>, java.io.Serializable, Cloneable, Comparable<ColumnStatisticsDesc> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnStatisticsDesc"); private static final org.apache.thrift.protocol.TField IS_TBL_LEVEL_FIELD_DESC = new org.apache.thrift.protocol.TField("isTblLevel", org.apache.thrift.protocol.TType.BOOL, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java index f1257fd,3c2b123..2be715f --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsObj.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class ColumnStatisticsObj implements org.apache.thrift.TBase<ColumnStatisticsObj, ColumnStatisticsObj._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class ColumnStatisticsObj implements org.apache.thrift.TBase<ColumnStatisticsObj, ColumnStatisticsObj._Fields>, java.io.Serializable, Cloneable, Comparable<ColumnStatisticsObj> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnStatisticsObj"); private static final org.apache.thrift.protocol.TField COL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("colName", org.apache.thrift.protocol.TType.STRING, (short)1); http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java ---------------------------------------------------------------------- diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java index aeb2421,5e8cd04..91483e2 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/CommitTxnRequest.java @@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated import org.slf4j.Logger; import org.slf4j.LoggerFactory; - public class CommitTxnRequest implements org.apache.thrift.TBase<CommitTxnRequest, CommitTxnRequest._Fields>, java.io.Serializable, Cloneable { + @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3") ++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14") + public class CommitTxnRequest implements org.apache.thrift.TBase<CommitTxnRequest, CommitTxnRequest._Fields>, java.io.Serializable, Cloneable, Comparable<CommitTxnRequest> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommitTxnRequest"); private static final org.apache.thrift.protocol.TField TXNID_FIELD_DESC = new org.apache.thrift.protocol.TField("txnid", org.apache.thrift.protocol.TType.I64, (short)1);