You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2015/04/15 03:11:49 UTC
svn commit: r1673599 [1/7] - in /hive/branches/cbo: ./
cli/src/java/org/apache/hadoop/hive/cli/
common/src/java/org/apache/hadoop/hive/common/type/
common/src/java/org/apache/hive/common/util/
hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapred...
Author: hashutosh
Date: Wed Apr 15 01:11:47 2015
New Revision: 1673599
URL: http://svn.apache.org/r1673599
Log:
Merged latest trunk into cbo branch (Ashutosh Chauhan)
Added:
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java
- copied unchanged from r1673598, hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Date.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java
- copied unchanged from r1673598, hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DateColumnStatsData.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRow.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRowDynBatch.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRowDynBatch.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRowSameBatch.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorAssignRowSameBatch.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnMapping.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnMapping.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnOrderedMap.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnOrderedMap.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnOutputMapping.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnOutputMapping.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnSourceMapping.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorColumnSourceMapping.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorCopyRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorCopyRow.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorDeserializeRow.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRow.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRowDynBatch.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRowDynBatch.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRowSameBatch.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorExtractRowSameBatch.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSerializeRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSerializeRow.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSerializeRowNoNulls.java
- copied unchanged from r1673598, hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSerializeRowNoNulls.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/RandomRowObjectSource.java
- copied unchanged from r1673598, hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/RandomRowObjectSource.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorRowObject.java
- copied unchanged from r1673598, hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorRowObject.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorSerDeRow.java
- copied unchanged from r1673598, hive/trunk/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorSerDeRow.java
hive/branches/cbo/ql/src/test/queries/clientpositive/compute_stats_date.q
- copied unchanged from r1673598, hive/trunk/ql/src/test/queries/clientpositive/compute_stats_date.q
hive/branches/cbo/ql/src/test/results/clientpositive/compute_stats_date.q.out
- copied unchanged from r1673598, hive/trunk/ql/src/test/results/clientpositive/compute_stats_date.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_date_1.q.out
- copied unchanged from r1673598, hive/trunk/ql/src/test/results/clientpositive/tez/vector_date_1.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_interval_1.q.out
- copied unchanged from r1673598, hive/trunk/ql/src/test/results/clientpositive/tez/vector_interval_1.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_interval_2.q.out
- copied unchanged from r1673598, hive/trunk/ql/src/test/results/clientpositive/tez/vector_interval_2.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_multi_insert.q.out
- copied unchanged from r1673598, hive/trunk/ql/src/test/results/clientpositive/tez/vector_multi_insert.q.out
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/
- copied from r1673598, hive/trunk/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/fast/
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/fast/
- copied from r1673598, hive/trunk/serde/src/java/org/apache/hadoop/hive/serde2/fast/
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/lazy/fast/
- copied from r1673598, hive/trunk/serde/src/java/org/apache/hadoop/hive/serde2/lazy/fast/
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/lazybinary/fast/
- copied from r1673598, hive/trunk/serde/src/java/org/apache/hadoop/hive/serde2/lazybinary/fast/
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java
- copied unchanged from r1673598, hive/trunk/serde/src/test/org/apache/hadoop/hive/serde2/VerifyFast.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/MyTestPrimitiveClass.java
- copied unchanged from r1673598, hive/trunk/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/MyTestPrimitiveClass.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java
- copied unchanged from r1673598, hive/trunk/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableFast.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/lazy/TestLazySimpleFast.java
- copied unchanged from r1673598, hive/trunk/serde/src/test/org/apache/hadoop/hive/serde2/lazy/TestLazySimpleFast.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/lazybinary/TestLazyBinaryFast.java
- copied unchanged from r1673598, hive/trunk/serde/src/test/org/apache/hadoop/hive/serde2/lazybinary/TestLazyBinaryFast.java
Modified:
hive/branches/cbo/ (props changed)
hive/branches/cbo/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
hive/branches/cbo/common/src/java/org/apache/hadoop/hive/common/type/HiveChar.java
hive/branches/cbo/common/src/java/org/apache/hive/common/util/DateUtils.java
hive/branches/cbo/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java
hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoader.java
hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderComplexSchema.java
hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderEncryption.java
hive/branches/cbo/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcWithMiniHS2.java
hive/branches/cbo/itests/src/test/resources/testconfiguration.properties
hive/branches/cbo/metastore/if/hive_metastore.thrift
hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Partition.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionListComposingSpec.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionSpecWithSharedSD.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionWithoutSD.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrincipalPrivilegeSet.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrivilegeBag.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/RequestPartsSpec.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Schema.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SerDeInfo.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SetPartitionsStatsRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SkewedInfo.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/StorageDescriptor.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Table.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsRequest.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableStatsResult.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
hive/branches/cbo/metastore/src/gen/thrift/gen-php/metastore/Types.php
hive/branches/cbo/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
hive/branches/cbo/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
hive/branches/cbo/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
hive/branches/cbo/metastore/src/java/org/apache/hadoop/hive/metastore/StatObjectConverter.java
hive/branches/cbo/metastore/src/model/org/apache/hadoop/hive/metastore/model/MPartitionColumnStatistics.java
hive/branches/cbo/metastore/src/model/org/apache/hadoop/hive/metastore/model/MTableColumnStatistics.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsUpdateTask.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordProcessor.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorGroupByOperator.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorMapJoinOperator.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSMBMapJoinOperator.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorSelectOperator.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizationContext.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedBatchUtil.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatch.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/exec/vector/VectorizedRowBatchCtx.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/metadata/formatting/MetaDataFormatUtils.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/Vectorizer.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ppr/PartitionPruner.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/plan/BaseWork.java
hive/branches/cbo/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFComputeStats.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorFilterOperator.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorGroupByOperator.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorSelectOperator.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/exec/vector/TestVectorizationContext.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/io/orc/TestInputOutputFormat.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/io/orc/TestOrcFile.java
hive/branches/cbo/ql/src/test/org/apache/hadoop/hive/ql/optimizer/physical/TestVectorizer.java
hive/branches/cbo/ql/src/test/results/clientpositive/annotate_stats_part.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/index_stale_partitioned.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/input42.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/input_part9.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_1.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_11.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_12.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_13.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_2.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_3.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_4.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_5.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_dml_9.q.java1.7.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/rand_partitionpruner3.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_aggregate_9.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_char_2.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_decimal_round.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_decimal_round_2.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/tez/vector_if_expr.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/truncate_column_list_bucket.q.out
hive/branches/cbo/ql/src/test/results/clientpositive/union_view.q.out
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/BinarySortableSerDe.java
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/binarysortable/InputByteBuffer.java
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyBinary.java
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/lazy/LazyUtils.java
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/lazybinary/LazyBinaryStruct.java
hive/branches/cbo/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/primitive/WritableHiveDecimalObjectInspector.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/TestStatsSerde.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/MyTestClass.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/binarysortable/TestBinarySortableSerDe.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/lazybinary/MyTestClassBigger.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/lazybinary/MyTestClassSmaller.java
hive/branches/cbo/serde/src/test/org/apache/hadoop/hive/serde2/lazybinary/TestLazyBinarySerDe.java
Propchange: hive/branches/cbo/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Wed Apr 15 01:11:47 2015
@@ -3,4 +3,4 @@
/hive/branches/spark:1608589-1660298
/hive/branches/tez:1494760-1622766
/hive/branches/vectorization:1466908-1527856
-/hive/trunk:1605012-1673252
+/hive/trunk:1605012-1673598
Modified: hive/branches/cbo/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java (original)
+++ hive/branches/cbo/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java Wed Apr 15 01:11:47 2015
@@ -767,6 +767,8 @@ public class CliDriver {
System.err.println(e.getMessage());
}
+ System.out.println("WARNING: Hive CLI is deprecated and migration to Beeline is recommended.");
+
// add shutdown hook to flush the history to history file
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
Modified: hive/branches/cbo/common/src/java/org/apache/hadoop/hive/common/type/HiveChar.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/common/src/java/org/apache/hadoop/hive/common/type/HiveChar.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/common/src/java/org/apache/hadoop/hive/common/type/HiveChar.java (original)
+++ hive/branches/cbo/common/src/java/org/apache/hadoop/hive/common/type/HiveChar.java Wed Apr 15 01:11:47 2015
@@ -55,7 +55,7 @@ public class HiveChar extends HiveBaseCh
return StringUtils.stripEnd(value, " ");
}
- protected String getPaddedValue() {
+ public String getPaddedValue() {
return value;
}
Modified: hive/branches/cbo/common/src/java/org/apache/hive/common/util/DateUtils.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/common/src/java/org/apache/hive/common/util/DateUtils.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/common/src/java/org/apache/hive/common/util/DateUtils.java (original)
+++ hive/branches/cbo/common/src/java/org/apache/hive/common/util/DateUtils.java Wed Apr 15 01:11:47 2015
@@ -65,5 +65,12 @@ public class DateUtils {
long totalNanos) {
intervalDayTime.set(totalNanos / NANOS_PER_SEC, (int) (totalNanos % NANOS_PER_SEC));
}
-}
+ public static long getIntervalDayTimeTotalSecondsFromTotalNanos(long totalNanos) {
+ return totalNanos / NANOS_PER_SEC;
+ }
+
+ public static int getIntervalDayTimeNanosFromTotalNanos(long totalNanos) {
+ return (int) (totalNanos % NANOS_PER_SEC);
+ }
+}
Modified: hive/branches/cbo/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java (original)
+++ hive/branches/cbo/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/HCatBaseTest.java Wed Apr 15 01:11:47 2015
@@ -24,7 +24,9 @@ import org.apache.hadoop.hive.cli.CliSes
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.metastore.HiveMetaStoreClient;
import org.apache.hadoop.hive.ql.Driver;
+import org.apache.hadoop.hive.ql.WindowsPathUtil;
import org.apache.hadoop.hive.ql.session.SessionState;
+import org.apache.hadoop.util.Shell;
import org.apache.hive.hcatalog.common.HCatUtil;
import org.apache.pig.ExecType;
import org.apache.pig.PigServer;
@@ -81,6 +83,10 @@ public class HCatBaseTest {
hiveConf.setVar(HiveConf.ConfVars.POSTEXECHOOKS, "");
hiveConf.setBoolVar(HiveConf.ConfVars.HIVE_SUPPORT_CONCURRENCY, false);
hiveConf.setVar(HiveConf.ConfVars.METASTOREWAREHOUSE, TEST_WAREHOUSE_DIR);
+
+ if (Shell.WINDOWS) {
+ WindowsPathUtil.convertPathsFromWindowsToHdfs(hiveConf);
+ }
}
protected void logAndRegister(PigServer server, String query) throws IOException {
Modified: hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoader.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoader.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoader.java (original)
+++ hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoader.java Wed Apr 15 01:11:47 2015
@@ -44,6 +44,7 @@ import org.apache.hadoop.hive.cli.CliSes
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.CommandNeedRetryException;
import org.apache.hadoop.hive.ql.Driver;
+import org.apache.hadoop.hive.ql.WindowsPathUtil;
import org.apache.hadoop.hive.ql.io.IOConstants;
import org.apache.hadoop.hive.ql.io.StorageFormats;
import org.apache.hadoop.hive.ql.processors.CommandProcessorResponse;
@@ -51,6 +52,7 @@ import org.apache.hadoop.hive.ql.session
import org.apache.hadoop.hive.serde2.ColumnProjectionUtils;
import org.apache.hadoop.mapreduce.Job;
+import org.apache.hadoop.util.Shell;
import org.apache.hive.hcatalog.HcatTestUtils;
import org.apache.hive.hcatalog.common.HCatUtil;
import org.apache.hive.hcatalog.common.HCatConstants;
@@ -179,6 +181,11 @@ public class TestHCatLoader {
hiveConf.set(HiveConf.ConfVars.POSTEXECHOOKS.varname, "");
hiveConf.set(HiveConf.ConfVars.HIVE_SUPPORT_CONCURRENCY.varname, "false");
hiveConf.set(HiveConf.ConfVars.METASTOREWAREHOUSE.varname, TEST_WAREHOUSE_DIR);
+
+ if (Shell.WINDOWS) {
+ WindowsPathUtil.convertPathsFromWindowsToHdfs(hiveConf);
+ }
+
driver = new Driver(hiveConf);
SessionState.start(new CliSessionState(hiveConf));
Modified: hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderComplexSchema.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderComplexSchema.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderComplexSchema.java (original)
+++ hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderComplexSchema.java Wed Apr 15 01:11:47 2015
@@ -33,11 +33,13 @@ import org.apache.hadoop.hive.cli.CliSes
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.CommandNeedRetryException;
import org.apache.hadoop.hive.ql.Driver;
+import org.apache.hadoop.hive.ql.WindowsPathUtil;
import org.apache.hadoop.hive.ql.io.IOConstants;
import org.apache.hadoop.hive.ql.io.StorageFormats;
import org.apache.hadoop.hive.ql.processors.CommandProcessorResponse;
import org.apache.hadoop.hive.ql.session.SessionState;
+import org.apache.hadoop.util.Shell;
import org.apache.pig.ExecType;
import org.apache.pig.PigServer;
import org.apache.pig.backend.executionengine.ExecException;
@@ -123,6 +125,11 @@ public class TestHCatLoaderComplexSchema
hiveConf.set(HiveConf.ConfVars.PREEXECHOOKS.varname, "");
hiveConf.set(HiveConf.ConfVars.POSTEXECHOOKS.varname, "");
hiveConf.set(HiveConf.ConfVars.HIVE_SUPPORT_CONCURRENCY.varname, "false");
+
+ if (Shell.WINDOWS) {
+ WindowsPathUtil.convertPathsFromWindowsToHdfs(hiveConf);
+ }
+
driver = new Driver(hiveConf);
SessionState.start(new CliSessionState(hiveConf));
//props = new Properties();
Modified: hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderEncryption.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderEncryption.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderEncryption.java (original)
+++ hive/branches/cbo/hcatalog/hcatalog-pig-adapter/src/test/java/org/apache/hive/hcatalog/pig/TestHCatLoaderEncryption.java Wed Apr 15 01:11:47 2015
@@ -42,6 +42,7 @@ import org.apache.hadoop.hive.conf.HiveC
import org.apache.hadoop.hive.metastore.MetaStoreUtils;
import org.apache.hadoop.hive.ql.CommandNeedRetryException;
import org.apache.hadoop.hive.ql.Driver;
+import org.apache.hadoop.hive.ql.WindowsPathUtil;
import org.apache.hadoop.hive.ql.io.IOConstants;
import org.apache.hadoop.hive.ql.io.StorageFormats;
import org.apache.hadoop.hive.ql.processors.CommandProcessor;
@@ -58,6 +59,7 @@ import org.apache.hadoop.io.WritableComp
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;
+import org.apache.hadoop.util.Shell;
import org.apache.hive.hcatalog.HcatTestUtils;
import org.apache.hive.hcatalog.common.HCatUtil;
import org.apache.hive.hcatalog.data.HCatRecord;
@@ -177,6 +179,11 @@ public class TestHCatLoaderEncryption {
hiveConf.set(HiveConf.ConfVars.POSTEXECHOOKS.varname, "");
hiveConf.set(HiveConf.ConfVars.HIVE_SUPPORT_CONCURRENCY.varname, "false");
hiveConf.set(HiveConf.ConfVars.METASTOREWAREHOUSE.varname, TEST_WAREHOUSE_DIR);
+
+ if (Shell.WINDOWS) {
+ WindowsPathUtil.convertPathsFromWindowsToHdfs(hiveConf);
+ }
+
driver = new Driver(hiveConf);
checkShimLoaderVersion();
Modified: hive/branches/cbo/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcWithMiniHS2.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcWithMiniHS2.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcWithMiniHS2.java (original)
+++ hive/branches/cbo/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcWithMiniHS2.java Wed Apr 15 01:11:47 2015
@@ -266,7 +266,7 @@ public class TestJdbcWithMiniHS2 {
// Set some conf parameters
String hiveConf = "hive.cli.print.header=true;hive.server2.async.exec.shutdown.timeout=20;"
- + "hive.server2.async.exec.threads=30;hive.server2.thrift.http.max.worker.threads=15";
+ + "hive.server2.async.exec.threads=30;hive.server2.thrift.max.worker.threads=15";
// Set some conf vars
String hiveVar = "stab=salesTable;icol=customerID";
String jdbcUri = miniHS2.getJdbcURL() + "?" + hiveConf + "#" + hiveVar;
@@ -284,7 +284,7 @@ public class TestJdbcWithMiniHS2 {
verifyConfProperty(stmt, "hive.cli.print.header", "true");
verifyConfProperty(stmt, "hive.server2.async.exec.shutdown.timeout", "20");
verifyConfProperty(stmt, "hive.server2.async.exec.threads", "30");
- verifyConfProperty(stmt, "hive.server2.thrift.http.max.worker.threads",
+ verifyConfProperty(stmt, "hive.server2.thrift.max.worker.threads",
"15");
verifyConfProperty(stmt, "stab", "salesTable");
verifyConfProperty(stmt, "icol", "customerID");
Modified: hive/branches/cbo/itests/src/test/resources/testconfiguration.properties
URL: http://svn.apache.org/viewvc/hive/branches/cbo/itests/src/test/resources/testconfiguration.properties?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/itests/src/test/resources/testconfiguration.properties (original)
+++ hive/branches/cbo/itests/src/test/resources/testconfiguration.properties Wed Apr 15 01:11:47 2015
@@ -181,9 +181,11 @@ minitez.query.files.shared=alter_merge_2
update_where_non_partitioned.q,\
update_where_partitioned.q,\
update_two_cols.q,\
+ vector_aggregate_9.q,\
vector_between_in.q,\
vector_bucket.q,\
vector_cast_constant.q,\
+ vector_char_2.q,\
vector_char_4.q,\
vector_char_mapjoin1.q,\
vector_char_simple.q,\
@@ -191,6 +193,7 @@ minitez.query.files.shared=alter_merge_2
vector_coalesce_2.q,\
vector_count_distinct.q,\
vector_data_types.q,\
+ vector_date_1.q,\
vector_decimal_1.q,\
vector_decimal_10_0.q,\
vector_decimal_2.q,\
@@ -204,6 +207,8 @@ minitez.query.files.shared=alter_merge_2
vector_decimal_mapjoin.q,\
vector_decimal_math_funcs.q,\
vector_decimal_precision.q,\
+ vector_decimal_round.q,\
+ vector_decimal_round_2.q,\
vector_decimal_trailing.q,\
vector_decimal_udf.q,\
vector_decimal_udf2.q,\
@@ -211,8 +216,12 @@ minitez.query.files.shared=alter_merge_2
vector_elt.q,\
vector_groupby_3.q,\
vector_groupby_reduce.q,\
+ vector_if_expr.q,\
+ vector_interval_1.q,\
+ vector_interval_2.q,\
vector_left_outer_join.q,\
vector_mapjoin_reduce.q,\
+ vector_multi_insert.q,\
vector_non_string_partition.q,\
vector_orderby_5.q,\
vector_partition_diff_num_cols.q,\
Modified: hive/branches/cbo/metastore/if/hive_metastore.thrift
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/if/hive_metastore.thrift?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/if/hive_metastore.thrift (original)
+++ hive/branches/cbo/metastore/if/hive_metastore.thrift Wed Apr 15 01:11:47 2015
@@ -368,13 +368,25 @@ struct DecimalColumnStatsData {
4: required i64 numDVs
}
+struct Date {
+1: required i64 daysSinceEpoch
+}
+
+struct DateColumnStatsData {
+1: optional Date lowValue,
+2: optional Date highValue,
+3: required i64 numNulls,
+4: required i64 numDVs
+}
+
union ColumnStatisticsData {
1: BooleanColumnStatsData booleanStats,
2: LongColumnStatsData longStats,
3: DoubleColumnStatsData doubleStats,
4: StringColumnStatsData stringStats,
5: BinaryColumnStatsData binaryStats,
-6: DecimalColumnStatsData decimalStats
+6: DecimalColumnStatsData decimalStats,
+7: DateColumnStatsData dateStats
}
struct ColumnStatisticsObj {
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.cpp Wed Apr 15 01:11:47 2015
@@ -4697,8 +4697,181 @@ void swap(DecimalColumnStatsData &a, Dec
swap(a.__isset, b.__isset);
}
-const char* ColumnStatisticsData::ascii_fingerprint = "D079ACEA6EE0998D0A45CB65FF1EAADD";
-const uint8_t ColumnStatisticsData::binary_fingerprint[16] = {0xD0,0x79,0xAC,0xEA,0x6E,0xE0,0x99,0x8D,0x0A,0x45,0xCB,0x65,0xFF,0x1E,0xAA,0xDD};
+const char* Date::ascii_fingerprint = "56A59CE7FFAF82BCA8A19FAACDE4FB75";
+const uint8_t Date::binary_fingerprint[16] = {0x56,0xA5,0x9C,0xE7,0xFF,0xAF,0x82,0xBC,0xA8,0xA1,0x9F,0xAA,0xCD,0xE4,0xFB,0x75};
+
+uint32_t Date::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;
+
+ bool isset_daysSinceEpoch = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->daysSinceEpoch);
+ isset_daysSinceEpoch = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_daysSinceEpoch)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t Date::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("Date");
+
+ xfer += oprot->writeFieldBegin("daysSinceEpoch", ::apache::thrift::protocol::T_I64, 1);
+ xfer += oprot->writeI64(this->daysSinceEpoch);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(Date &a, Date &b) {
+ using ::std::swap;
+ swap(a.daysSinceEpoch, b.daysSinceEpoch);
+}
+
+const char* DateColumnStatsData::ascii_fingerprint = "D0719F3BBA8248297BB5287552897F59";
+const uint8_t DateColumnStatsData::binary_fingerprint[16] = {0xD0,0x71,0x9F,0x3B,0xBA,0x82,0x48,0x29,0x7B,0xB5,0x28,0x75,0x52,0x89,0x7F,0x59};
+
+uint32_t DateColumnStatsData::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;
+
+ bool isset_numNulls = false;
+ bool isset_numDVs = false;
+
+ while (true)
+ {
+ xfer += iprot->readFieldBegin(fname, ftype, fid);
+ if (ftype == ::apache::thrift::protocol::T_STOP) {
+ break;
+ }
+ switch (fid)
+ {
+ case 1:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->lowValue.read(iprot);
+ this->__isset.lowValue = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 2:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->highValue.read(iprot);
+ this->__isset.highValue = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 3:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->numNulls);
+ isset_numNulls = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ case 4:
+ if (ftype == ::apache::thrift::protocol::T_I64) {
+ xfer += iprot->readI64(this->numDVs);
+ isset_numDVs = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
+ default:
+ xfer += iprot->skip(ftype);
+ break;
+ }
+ xfer += iprot->readFieldEnd();
+ }
+
+ xfer += iprot->readStructEnd();
+
+ if (!isset_numNulls)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ if (!isset_numDVs)
+ throw TProtocolException(TProtocolException::INVALID_DATA);
+ return xfer;
+}
+
+uint32_t DateColumnStatsData::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ uint32_t xfer = 0;
+ xfer += oprot->writeStructBegin("DateColumnStatsData");
+
+ if (this->__isset.lowValue) {
+ xfer += oprot->writeFieldBegin("lowValue", ::apache::thrift::protocol::T_STRUCT, 1);
+ xfer += this->lowValue.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ if (this->__isset.highValue) {
+ xfer += oprot->writeFieldBegin("highValue", ::apache::thrift::protocol::T_STRUCT, 2);
+ xfer += this->highValue.write(oprot);
+ xfer += oprot->writeFieldEnd();
+ }
+ xfer += oprot->writeFieldBegin("numNulls", ::apache::thrift::protocol::T_I64, 3);
+ xfer += oprot->writeI64(this->numNulls);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldBegin("numDVs", ::apache::thrift::protocol::T_I64, 4);
+ xfer += oprot->writeI64(this->numDVs);
+ xfer += oprot->writeFieldEnd();
+
+ xfer += oprot->writeFieldStop();
+ xfer += oprot->writeStructEnd();
+ return xfer;
+}
+
+void swap(DateColumnStatsData &a, DateColumnStatsData &b) {
+ using ::std::swap;
+ swap(a.lowValue, b.lowValue);
+ swap(a.highValue, b.highValue);
+ swap(a.numNulls, b.numNulls);
+ swap(a.numDVs, b.numDVs);
+ swap(a.__isset, b.__isset);
+}
+
+const char* ColumnStatisticsData::ascii_fingerprint = "15E449CA15A23E37F2D54C31ACA52106";
+const uint8_t ColumnStatisticsData::binary_fingerprint[16] = {0x15,0xE4,0x49,0xCA,0x15,0xA2,0x3E,0x37,0xF2,0xD5,0x4C,0x31,0xAC,0xA5,0x21,0x06};
uint32_t ColumnStatisticsData::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -4768,6 +4941,14 @@ uint32_t ColumnStatisticsData::read(::ap
xfer += iprot->skip(ftype);
}
break;
+ case 7:
+ if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+ xfer += this->dateStats.read(iprot);
+ this->__isset.dateStats = true;
+ } else {
+ xfer += iprot->skip(ftype);
+ }
+ break;
default:
xfer += iprot->skip(ftype);
break;
@@ -4808,6 +4989,10 @@ uint32_t ColumnStatisticsData::write(::a
xfer += this->decimalStats.write(oprot);
xfer += oprot->writeFieldEnd();
+ xfer += oprot->writeFieldBegin("dateStats", ::apache::thrift::protocol::T_STRUCT, 7);
+ xfer += this->dateStats.write(oprot);
+ xfer += oprot->writeFieldEnd();
+
xfer += oprot->writeFieldStop();
xfer += oprot->writeStructEnd();
return xfer;
@@ -4821,11 +5006,12 @@ void swap(ColumnStatisticsData &a, Colum
swap(a.stringStats, b.stringStats);
swap(a.binaryStats, b.binaryStats);
swap(a.decimalStats, b.decimalStats);
+ swap(a.dateStats, b.dateStats);
swap(a.__isset, b.__isset);
}
-const char* ColumnStatisticsObj::ascii_fingerprint = "E49E62CFC71682004614EFEDAC3CD3F4";
-const uint8_t ColumnStatisticsObj::binary_fingerprint[16] = {0xE4,0x9E,0x62,0xCF,0xC7,0x16,0x82,0x00,0x46,0x14,0xEF,0xED,0xAC,0x3C,0xD3,0xF4};
+const char* ColumnStatisticsObj::ascii_fingerprint = "A82BA819C9FFEDDEBC0D50F6F4E46534";
+const uint8_t ColumnStatisticsObj::binary_fingerprint[16] = {0xA8,0x2B,0xA8,0x19,0xC9,0xFF,0xED,0xDE,0xBC,0x0D,0x50,0xF6,0xF4,0xE4,0x65,0x34};
uint32_t ColumnStatisticsObj::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5045,8 +5231,8 @@ void swap(ColumnStatisticsDesc &a, Colum
swap(a.__isset, b.__isset);
}
-const char* ColumnStatistics::ascii_fingerprint = "6682E234199B2CD3807B1ED420C6A7F8";
-const uint8_t ColumnStatistics::binary_fingerprint[16] = {0x66,0x82,0xE2,0x34,0x19,0x9B,0x2C,0xD3,0x80,0x7B,0x1E,0xD4,0x20,0xC6,0xA7,0xF8};
+const char* ColumnStatistics::ascii_fingerprint = "8A64D0A67FFD3A372726A320B3913D5A";
+const uint8_t ColumnStatistics::binary_fingerprint[16] = {0x8A,0x64,0xD0,0xA6,0x7F,0xFD,0x3A,0x37,0x27,0x26,0xA3,0x20,0xB3,0x91,0x3D,0x5A};
uint32_t ColumnStatistics::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5145,8 +5331,8 @@ void swap(ColumnStatistics &a, ColumnSta
swap(a.statsObj, b.statsObj);
}
-const char* AggrStats::ascii_fingerprint = "399BDBAF7503E0BFB5E1D99C83D790CD";
-const uint8_t AggrStats::binary_fingerprint[16] = {0x39,0x9B,0xDB,0xAF,0x75,0x03,0xE0,0xBF,0xB5,0xE1,0xD9,0x9C,0x83,0xD7,0x90,0xCD};
+const char* AggrStats::ascii_fingerprint = "1FC765A3AB2954591C14B0D946778213";
+const uint8_t AggrStats::binary_fingerprint[16] = {0x1F,0xC7,0x65,0xA3,0xAB,0x29,0x54,0x59,0x1C,0x14,0xB0,0xD9,0x46,0x77,0x82,0x13};
uint32_t AggrStats::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5245,8 +5431,8 @@ void swap(AggrStats &a, AggrStats &b) {
swap(a.partsFound, b.partsFound);
}
-const char* SetPartitionsStatsRequest::ascii_fingerprint = "635C0DA9A947DA57AAE693A5DFB86569";
-const uint8_t SetPartitionsStatsRequest::binary_fingerprint[16] = {0x63,0x5C,0x0D,0xA9,0xA9,0x47,0xDA,0x57,0xAA,0xE6,0x93,0xA5,0xDF,0xB8,0x65,0x69};
+const char* SetPartitionsStatsRequest::ascii_fingerprint = "8BCBF2CE9E942D0FB7D8F4ED57D8DC27";
+const uint8_t SetPartitionsStatsRequest::binary_fingerprint[16] = {0x8B,0xCB,0xF2,0xCE,0x9E,0x94,0x2D,0x0F,0xB7,0xD8,0xF4,0xED,0x57,0xD8,0xDC,0x27};
uint32_t SetPartitionsStatsRequest::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5759,8 +5945,8 @@ void swap(PartitionsByExprRequest &a, Pa
swap(a.__isset, b.__isset);
}
-const char* TableStatsResult::ascii_fingerprint = "CE3E8F0D9B310B8D33CB7A89A75F3E05";
-const uint8_t TableStatsResult::binary_fingerprint[16] = {0xCE,0x3E,0x8F,0x0D,0x9B,0x31,0x0B,0x8D,0x33,0xCB,0x7A,0x89,0xA7,0x5F,0x3E,0x05};
+const char* TableStatsResult::ascii_fingerprint = "2E398BAC949C93A194F1A19CA5074FF8";
+const uint8_t TableStatsResult::binary_fingerprint[16] = {0x2E,0x39,0x8B,0xAC,0x94,0x9C,0x93,0xA1,0x94,0xF1,0xA1,0x9C,0xA5,0x07,0x4F,0xF8};
uint32_t TableStatsResult::read(::apache::thrift::protocol::TProtocol* iprot) {
@@ -5843,8 +6029,8 @@ void swap(TableStatsResult &a, TableStat
swap(a.tableStats, b.tableStats);
}
-const char* PartitionsStatsResult::ascii_fingerprint = "FF175B50C5EF6F442D3AF25B06435A39";
-const uint8_t PartitionsStatsResult::binary_fingerprint[16] = {0xFF,0x17,0x5B,0x50,0xC5,0xEF,0x6F,0x44,0x2D,0x3A,0xF2,0x5B,0x06,0x43,0x5A,0x39};
+const char* PartitionsStatsResult::ascii_fingerprint = "DD38B4AA7D02E288659AA12CBAAEF33B";
+const uint8_t PartitionsStatsResult::binary_fingerprint[16] = {0xDD,0x38,0xB4,0xAA,0x7D,0x02,0xE2,0x88,0x65,0x9A,0xA1,0x2C,0xBA,0xAE,0xF3,0x3B};
uint32_t PartitionsStatsResult::read(::apache::thrift::protocol::TProtocol* iprot) {
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-cpp/hive_metastore_types.h Wed Apr 15 01:11:47 2015
@@ -2652,21 +2652,130 @@ class DecimalColumnStatsData {
void swap(DecimalColumnStatsData &a, DecimalColumnStatsData &b);
+
+class Date {
+ public:
+
+ static const char* ascii_fingerprint; // = "56A59CE7FFAF82BCA8A19FAACDE4FB75";
+ static const uint8_t binary_fingerprint[16]; // = {0x56,0xA5,0x9C,0xE7,0xFF,0xAF,0x82,0xBC,0xA8,0xA1,0x9F,0xAA,0xCD,0xE4,0xFB,0x75};
+
+ Date() : daysSinceEpoch(0) {
+ }
+
+ virtual ~Date() throw() {}
+
+ int64_t daysSinceEpoch;
+
+ void __set_daysSinceEpoch(const int64_t val) {
+ daysSinceEpoch = val;
+ }
+
+ bool operator == (const Date & rhs) const
+ {
+ if (!(daysSinceEpoch == rhs.daysSinceEpoch))
+ return false;
+ return true;
+ }
+ bool operator != (const Date &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const Date & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(Date &a, Date &b);
+
+typedef struct _DateColumnStatsData__isset {
+ _DateColumnStatsData__isset() : lowValue(false), highValue(false) {}
+ bool lowValue;
+ bool highValue;
+} _DateColumnStatsData__isset;
+
+class DateColumnStatsData {
+ public:
+
+ static const char* ascii_fingerprint; // = "D0719F3BBA8248297BB5287552897F59";
+ static const uint8_t binary_fingerprint[16]; // = {0xD0,0x71,0x9F,0x3B,0xBA,0x82,0x48,0x29,0x7B,0xB5,0x28,0x75,0x52,0x89,0x7F,0x59};
+
+ DateColumnStatsData() : numNulls(0), numDVs(0) {
+ }
+
+ virtual ~DateColumnStatsData() throw() {}
+
+ Date lowValue;
+ Date highValue;
+ int64_t numNulls;
+ int64_t numDVs;
+
+ _DateColumnStatsData__isset __isset;
+
+ void __set_lowValue(const Date& val) {
+ lowValue = val;
+ __isset.lowValue = true;
+ }
+
+ void __set_highValue(const Date& val) {
+ highValue = val;
+ __isset.highValue = true;
+ }
+
+ void __set_numNulls(const int64_t val) {
+ numNulls = val;
+ }
+
+ void __set_numDVs(const int64_t val) {
+ numDVs = val;
+ }
+
+ bool operator == (const DateColumnStatsData & rhs) const
+ {
+ if (__isset.lowValue != rhs.__isset.lowValue)
+ return false;
+ else if (__isset.lowValue && !(lowValue == rhs.lowValue))
+ return false;
+ if (__isset.highValue != rhs.__isset.highValue)
+ return false;
+ else if (__isset.highValue && !(highValue == rhs.highValue))
+ return false;
+ if (!(numNulls == rhs.numNulls))
+ return false;
+ if (!(numDVs == rhs.numDVs))
+ return false;
+ return true;
+ }
+ bool operator != (const DateColumnStatsData &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const DateColumnStatsData & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+void swap(DateColumnStatsData &a, DateColumnStatsData &b);
+
typedef struct _ColumnStatisticsData__isset {
- _ColumnStatisticsData__isset() : booleanStats(false), longStats(false), doubleStats(false), stringStats(false), binaryStats(false), decimalStats(false) {}
+ _ColumnStatisticsData__isset() : booleanStats(false), longStats(false), doubleStats(false), stringStats(false), binaryStats(false), decimalStats(false), dateStats(false) {}
bool booleanStats;
bool longStats;
bool doubleStats;
bool stringStats;
bool binaryStats;
bool decimalStats;
+ bool dateStats;
} _ColumnStatisticsData__isset;
class ColumnStatisticsData {
public:
- static const char* ascii_fingerprint; // = "D079ACEA6EE0998D0A45CB65FF1EAADD";
- static const uint8_t binary_fingerprint[16]; // = {0xD0,0x79,0xAC,0xEA,0x6E,0xE0,0x99,0x8D,0x0A,0x45,0xCB,0x65,0xFF,0x1E,0xAA,0xDD};
+ static const char* ascii_fingerprint; // = "15E449CA15A23E37F2D54C31ACA52106";
+ static const uint8_t binary_fingerprint[16]; // = {0x15,0xE4,0x49,0xCA,0x15,0xA2,0x3E,0x37,0xF2,0xD5,0x4C,0x31,0xAC,0xA5,0x21,0x06};
ColumnStatisticsData() {
}
@@ -2679,6 +2788,7 @@ class ColumnStatisticsData {
StringColumnStatsData stringStats;
BinaryColumnStatsData binaryStats;
DecimalColumnStatsData decimalStats;
+ DateColumnStatsData dateStats;
_ColumnStatisticsData__isset __isset;
@@ -2706,6 +2816,10 @@ class ColumnStatisticsData {
decimalStats = val;
}
+ void __set_dateStats(const DateColumnStatsData& val) {
+ dateStats = val;
+ }
+
bool operator == (const ColumnStatisticsData & rhs) const
{
if (!(booleanStats == rhs.booleanStats))
@@ -2720,6 +2834,8 @@ class ColumnStatisticsData {
return false;
if (!(decimalStats == rhs.decimalStats))
return false;
+ if (!(dateStats == rhs.dateStats))
+ return false;
return true;
}
bool operator != (const ColumnStatisticsData &rhs) const {
@@ -2739,8 +2855,8 @@ void swap(ColumnStatisticsData &a, Colum
class ColumnStatisticsObj {
public:
- static const char* ascii_fingerprint; // = "E49E62CFC71682004614EFEDAC3CD3F4";
- static const uint8_t binary_fingerprint[16]; // = {0xE4,0x9E,0x62,0xCF,0xC7,0x16,0x82,0x00,0x46,0x14,0xEF,0xED,0xAC,0x3C,0xD3,0xF4};
+ static const char* ascii_fingerprint; // = "A82BA819C9FFEDDEBC0D50F6F4E46534";
+ static const uint8_t binary_fingerprint[16]; // = {0xA8,0x2B,0xA8,0x19,0xC9,0xFF,0xED,0xDE,0xBC,0x0D,0x50,0xF6,0xF4,0xE4,0x65,0x34};
ColumnStatisticsObj() : colName(), colType() {
}
@@ -2868,8 +2984,8 @@ void swap(ColumnStatisticsDesc &a, Colum
class ColumnStatistics {
public:
- static const char* ascii_fingerprint; // = "6682E234199B2CD3807B1ED420C6A7F8";
- static const uint8_t binary_fingerprint[16]; // = {0x66,0x82,0xE2,0x34,0x19,0x9B,0x2C,0xD3,0x80,0x7B,0x1E,0xD4,0x20,0xC6,0xA7,0xF8};
+ static const char* ascii_fingerprint; // = "8A64D0A67FFD3A372726A320B3913D5A";
+ static const uint8_t binary_fingerprint[16]; // = {0x8A,0x64,0xD0,0xA6,0x7F,0xFD,0x3A,0x37,0x27,0x26,0xA3,0x20,0xB3,0x91,0x3D,0x5A};
ColumnStatistics() {
}
@@ -2912,8 +3028,8 @@ void swap(ColumnStatistics &a, ColumnSta
class AggrStats {
public:
- static const char* ascii_fingerprint; // = "399BDBAF7503E0BFB5E1D99C83D790CD";
- static const uint8_t binary_fingerprint[16]; // = {0x39,0x9B,0xDB,0xAF,0x75,0x03,0xE0,0xBF,0xB5,0xE1,0xD9,0x9C,0x83,0xD7,0x90,0xCD};
+ static const char* ascii_fingerprint; // = "1FC765A3AB2954591C14B0D946778213";
+ static const uint8_t binary_fingerprint[16]; // = {0x1F,0xC7,0x65,0xA3,0xAB,0x29,0x54,0x59,0x1C,0x14,0xB0,0xD9,0x46,0x77,0x82,0x13};
AggrStats() : partsFound(0) {
}
@@ -2956,8 +3072,8 @@ void swap(AggrStats &a, AggrStats &b);
class SetPartitionsStatsRequest {
public:
- static const char* ascii_fingerprint; // = "635C0DA9A947DA57AAE693A5DFB86569";
- static const uint8_t binary_fingerprint[16]; // = {0x63,0x5C,0x0D,0xA9,0xA9,0x47,0xDA,0x57,0xAA,0xE6,0x93,0xA5,0xDF,0xB8,0x65,0x69};
+ static const char* ascii_fingerprint; // = "8BCBF2CE9E942D0FB7D8F4ED57D8DC27";
+ static const uint8_t binary_fingerprint[16]; // = {0x8B,0xCB,0xF2,0xCE,0x9E,0x94,0x2D,0x0F,0xB7,0xD8,0xF4,0xED,0x57,0xD8,0xDC,0x27};
SetPartitionsStatsRequest() {
}
@@ -3209,8 +3325,8 @@ void swap(PartitionsByExprRequest &a, Pa
class TableStatsResult {
public:
- static const char* ascii_fingerprint; // = "CE3E8F0D9B310B8D33CB7A89A75F3E05";
- static const uint8_t binary_fingerprint[16]; // = {0xCE,0x3E,0x8F,0x0D,0x9B,0x31,0x0B,0x8D,0x33,0xCB,0x7A,0x89,0xA7,0x5F,0x3E,0x05};
+ static const char* ascii_fingerprint; // = "2E398BAC949C93A194F1A19CA5074FF8";
+ static const uint8_t binary_fingerprint[16]; // = {0x2E,0x39,0x8B,0xAC,0x94,0x9C,0x93,0xA1,0x94,0xF1,0xA1,0x9C,0xA5,0x07,0x4F,0xF8};
TableStatsResult() {
}
@@ -3246,8 +3362,8 @@ void swap(TableStatsResult &a, TableStat
class PartitionsStatsResult {
public:
- static const char* ascii_fingerprint; // = "FF175B50C5EF6F442D3AF25B06435A39";
- static const uint8_t binary_fingerprint[16]; // = {0xFF,0x17,0x5B,0x50,0xC5,0xEF,0x6F,0x44,0x2D,0x3A,0xF2,0x5B,0x06,0x43,0x5A,0x39};
+ static const char* ascii_fingerprint; // = "DD38B4AA7D02E288659AA12CBAAEF33B";
+ static const uint8_t binary_fingerprint[16]; // = {0xDD,0x38,0xB4,0xAA,0x7D,0x02,0xE2,0x88,0x65,0x9A,0xA1,0x2C,0xBA,0xAE,0xF3,0x3B};
PartitionsStatsResult() {
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddDynamicPartitions.java Wed Apr 15 01:11:47 2015
@@ -633,7 +633,7 @@ public class AddDynamicPartitions implem
struct.partitionnames = new ArrayList<String>(_list492.size);
for (int _i493 = 0; _i493 < _list492.size; ++_i493)
{
- String _elem494; // required
+ String _elem494; // optional
_elem494 = iprot.readString();
struct.partitionnames.add(_elem494);
}
@@ -725,7 +725,7 @@ public class AddDynamicPartitions implem
struct.partitionnames = new ArrayList<String>(_list497.size);
for (int _i498 = 0; _i498 < _list497.size; ++_i498)
{
- String _elem499; // required
+ String _elem499; // optional
_elem499 = iprot.readString();
struct.partitionnames.add(_elem499);
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsRequest.java Wed Apr 15 01:11:47 2015
@@ -704,7 +704,7 @@ public class AddPartitionsRequest implem
struct.parts = new ArrayList<Partition>(_list388.size);
for (int _i389 = 0; _i389 < _list388.size; ++_i389)
{
- Partition _elem390; // required
+ Partition _elem390; // optional
_elem390 = new Partition();
_elem390.read(iprot);
struct.parts.add(_elem390);
@@ -824,7 +824,7 @@ public class AddPartitionsRequest implem
struct.parts = new ArrayList<Partition>(_list393.size);
for (int _i394 = 0; _i394 < _list393.size; ++_i394)
{
- Partition _elem395; // required
+ Partition _elem395; // optional
_elem395 = new Partition();
_elem395.read(iprot);
struct.parts.add(_elem395);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AddPartitionsResult.java Wed Apr 15 01:11:47 2015
@@ -346,7 +346,7 @@ public class AddPartitionsResult impleme
struct.partitions = new ArrayList<Partition>(_list380.size);
for (int _i381 = 0; _i381 < _list380.size; ++_i381)
{
- Partition _elem382; // required
+ Partition _elem382; // optional
_elem382 = new Partition();
_elem382.read(iprot);
struct.partitions.add(_elem382);
@@ -428,7 +428,7 @@ public class AddPartitionsResult impleme
struct.partitions = new ArrayList<Partition>(_list385.size);
for (int _i386 = 0; _i386 < _list385.size; ++_i386)
{
- Partition _elem387; // required
+ Partition _elem387; // optional
_elem387 = new Partition();
_elem387.read(iprot);
struct.partitions.add(_elem387);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/AggrStats.java Wed Apr 15 01:11:47 2015
@@ -439,7 +439,7 @@ public class AggrStats implements org.ap
struct.colStats = new ArrayList<ColumnStatisticsObj>(_list278.size);
for (int _i279 = 0; _i279 < _list278.size; ++_i279)
{
- ColumnStatisticsObj _elem280; // required
+ ColumnStatisticsObj _elem280; // optional
_elem280 = new ColumnStatisticsObj();
_elem280.read(iprot);
struct.colStats.add(_elem280);
@@ -522,7 +522,7 @@ public class AggrStats implements org.ap
struct.colStats = new ArrayList<ColumnStatisticsObj>(_list283.size);
for (int _i284 = 0; _i284 < _list283.size; ++_i284)
{
- ColumnStatisticsObj _elem285; // required
+ ColumnStatisticsObj _elem285; // optional
_elem285 = new ColumnStatisticsObj();
_elem285.read(iprot);
struct.colStats.add(_elem285);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatistics.java Wed Apr 15 01:11:47 2015
@@ -451,7 +451,7 @@ public class ColumnStatistics implements
struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list270.size);
for (int _i271 = 0; _i271 < _list270.size; ++_i271)
{
- ColumnStatisticsObj _elem272; // required
+ ColumnStatisticsObj _elem272; // optional
_elem272 = new ColumnStatisticsObj();
_elem272.read(iprot);
struct.statsObj.add(_elem272);
@@ -531,7 +531,7 @@ public class ColumnStatistics implements
struct.statsObj = new ArrayList<ColumnStatisticsObj>(_list275.size);
for (int _i276 = 0; _i276 < _list275.size; ++_i276)
{
- ColumnStatisticsObj _elem277; // required
+ ColumnStatisticsObj _elem277; // optional
_elem277 = new ColumnStatisticsObj();
_elem277.read(iprot);
struct.statsObj.add(_elem277);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ColumnStatisticsData.java Wed Apr 15 01:11:47 2015
@@ -39,6 +39,7 @@ public class ColumnStatisticsData extend
private static final org.apache.thrift.protocol.TField STRING_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("stringStats", org.apache.thrift.protocol.TType.STRUCT, (short)4);
private static final org.apache.thrift.protocol.TField BINARY_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("binaryStats", org.apache.thrift.protocol.TType.STRUCT, (short)5);
private static final org.apache.thrift.protocol.TField DECIMAL_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("decimalStats", org.apache.thrift.protocol.TType.STRUCT, (short)6);
+ private static final org.apache.thrift.protocol.TField DATE_STATS_FIELD_DESC = new org.apache.thrift.protocol.TField("dateStats", org.apache.thrift.protocol.TType.STRUCT, (short)7);
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -47,7 +48,8 @@ public class ColumnStatisticsData extend
DOUBLE_STATS((short)3, "doubleStats"),
STRING_STATS((short)4, "stringStats"),
BINARY_STATS((short)5, "binaryStats"),
- DECIMAL_STATS((short)6, "decimalStats");
+ DECIMAL_STATS((short)6, "decimalStats"),
+ DATE_STATS((short)7, "dateStats");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -74,6 +76,8 @@ public class ColumnStatisticsData extend
return BINARY_STATS;
case 6: // DECIMAL_STATS
return DECIMAL_STATS;
+ case 7: // DATE_STATS
+ return DATE_STATS;
default:
return null;
}
@@ -128,6 +132,8 @@ public class ColumnStatisticsData extend
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, BinaryColumnStatsData.class)));
tmpMap.put(_Fields.DECIMAL_STATS, new org.apache.thrift.meta_data.FieldMetaData("decimalStats", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DecimalColumnStatsData.class)));
+ tmpMap.put(_Fields.DATE_STATS, new org.apache.thrift.meta_data.FieldMetaData("dateStats", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, DateColumnStatsData.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(ColumnStatisticsData.class, metaDataMap);
}
@@ -183,6 +189,12 @@ public class ColumnStatisticsData extend
return x;
}
+ public static ColumnStatisticsData dateStats(DateColumnStatsData value) {
+ ColumnStatisticsData x = new ColumnStatisticsData();
+ x.setDateStats(value);
+ return x;
+ }
+
@Override
protected void checkType(_Fields setField, Object value) throws ClassCastException {
@@ -217,6 +229,11 @@ public class ColumnStatisticsData extend
break;
}
throw new ClassCastException("Was expecting value of type DecimalColumnStatsData for field 'decimalStats', but got " + value.getClass().getSimpleName());
+ case DATE_STATS:
+ if (value instanceof DateColumnStatsData) {
+ break;
+ }
+ throw new ClassCastException("Was expecting value of type DateColumnStatsData for field 'dateStats', but got " + value.getClass().getSimpleName());
default:
throw new IllegalArgumentException("Unknown field id " + setField);
}
@@ -287,6 +304,16 @@ public class ColumnStatisticsData extend
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
return null;
}
+ case DATE_STATS:
+ if (field.type == DATE_STATS_FIELD_DESC.type) {
+ DateColumnStatsData dateStats;
+ dateStats = new DateColumnStatsData();
+ dateStats.read(iprot);
+ return dateStats;
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+ return null;
+ }
default:
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
@@ -322,6 +349,10 @@ public class ColumnStatisticsData extend
DecimalColumnStatsData decimalStats = (DecimalColumnStatsData)value_;
decimalStats.write(oprot);
return;
+ case DATE_STATS:
+ DateColumnStatsData dateStats = (DateColumnStatsData)value_;
+ dateStats.write(oprot);
+ return;
default:
throw new IllegalStateException("Cannot write union with unknown field " + setField_);
}
@@ -362,6 +393,11 @@ public class ColumnStatisticsData extend
decimalStats = new DecimalColumnStatsData();
decimalStats.read(iprot);
return decimalStats;
+ case DATE_STATS:
+ DateColumnStatsData dateStats;
+ dateStats = new DateColumnStatsData();
+ dateStats.read(iprot);
+ return dateStats;
default:
throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
}
@@ -397,6 +433,10 @@ public class ColumnStatisticsData extend
DecimalColumnStatsData decimalStats = (DecimalColumnStatsData)value_;
decimalStats.write(oprot);
return;
+ case DATE_STATS:
+ DateColumnStatsData dateStats = (DateColumnStatsData)value_;
+ dateStats.write(oprot);
+ return;
default:
throw new IllegalStateException("Cannot write union with unknown field " + setField_);
}
@@ -417,6 +457,8 @@ public class ColumnStatisticsData extend
return BINARY_STATS_FIELD_DESC;
case DECIMAL_STATS:
return DECIMAL_STATS_FIELD_DESC;
+ case DATE_STATS:
+ return DATE_STATS_FIELD_DESC;
default:
throw new IllegalArgumentException("Unknown field id " + setField);
}
@@ -521,6 +563,20 @@ public class ColumnStatisticsData extend
value_ = value;
}
+ public DateColumnStatsData getDateStats() {
+ if (getSetField() == _Fields.DATE_STATS) {
+ return (DateColumnStatsData)getFieldValue();
+ } else {
+ throw new RuntimeException("Cannot get field 'dateStats' because union is currently set to " + getFieldDesc(getSetField()).name);
+ }
+ }
+
+ public void setDateStats(DateColumnStatsData value) {
+ if (value == null) throw new NullPointerException();
+ setField_ = _Fields.DATE_STATS;
+ value_ = value;
+ }
+
public boolean isSetBooleanStats() {
return setField_ == _Fields.BOOLEAN_STATS;
}
@@ -551,6 +607,11 @@ public class ColumnStatisticsData extend
}
+ public boolean isSetDateStats() {
+ return setField_ == _Fields.DATE_STATS;
+ }
+
+
public boolean equals(Object other) {
if (other instanceof ColumnStatisticsData) {
return equals((ColumnStatisticsData)other);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/DropPartitionsResult.java Wed Apr 15 01:11:47 2015
@@ -346,7 +346,7 @@ public class DropPartitionsResult implem
struct.partitions = new ArrayList<Partition>(_list396.size);
for (int _i397 = 0; _i397 < _list396.size; ++_i397)
{
- Partition _elem398; // required
+ Partition _elem398; // optional
_elem398 = new Partition();
_elem398.read(iprot);
struct.partitions.add(_elem398);
@@ -428,7 +428,7 @@ public class DropPartitionsResult implem
struct.partitions = new ArrayList<Partition>(_list401.size);
for (int _i402 = 0; _i402 < _list401.size; ++_i402)
{
- Partition _elem403; // required
+ Partition _elem403; // optional
_elem403 = new Partition();
_elem403.read(iprot);
struct.partitions.add(_elem403);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FieldSchema.java Wed Apr 15 01:11:47 2015
@@ -135,9 +135,9 @@ public class FieldSchema implements org.
String comment)
{
this();
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(name);
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(type);
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(comment);
+ this.name = name;
+ this.type = type;
+ this.comment = comment;
}
/**
@@ -145,13 +145,13 @@ public class FieldSchema implements org.
*/
public FieldSchema(FieldSchema other) {
if (other.isSetName()) {
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(other.name);
+ this.name = other.name;
}
if (other.isSetType()) {
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(other.type);
+ this.type = other.type;
}
if (other.isSetComment()) {
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(other.comment);
+ this.comment = other.comment;
}
}
@@ -171,7 +171,7 @@ public class FieldSchema implements org.
}
public void setName(String name) {
- this.name = org.apache.hive.common.util.HiveStringUtils.intern(name);
+ this.name = name;
}
public void unsetName() {
@@ -194,7 +194,7 @@ public class FieldSchema implements org.
}
public void setType(String type) {
- this.type = org.apache.hive.common.util.HiveStringUtils.intern(type);
+ this.type = type;
}
public void unsetType() {
@@ -217,7 +217,7 @@ public class FieldSchema implements org.
}
public void setComment(String comment) {
- this.comment = org.apache.hive.common.util.HiveStringUtils.intern(comment);
+ this.comment = comment;
}
public void unsetComment() {
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/FireEventRequest.java Wed Apr 15 01:11:47 2015
@@ -716,7 +716,7 @@ public class FireEventRequest implements
struct.partitionVals = new ArrayList<String>(_list516.size);
for (int _i517 = 0; _i517 < _list516.size; ++_i517)
{
- String _elem518; // required
+ String _elem518; // optional
_elem518 = iprot.readString();
struct.partitionVals.add(_elem518);
}
@@ -846,7 +846,7 @@ public class FireEventRequest implements
struct.partitionVals = new ArrayList<String>(_list521.size);
for (int _i522 = 0; _i522 < _list521.size; ++_i522)
{
- String _elem523; // required
+ String _elem523; // optional
_elem523 = iprot.readString();
struct.partitionVals.add(_elem523);
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Function.java Wed Apr 15 01:11:47 2015
@@ -997,7 +997,7 @@ public class Function implements org.apa
struct.resourceUris = new ArrayList<ResourceUri>(_list420.size);
for (int _i421 = 0; _i421 < _list420.size; ++_i421)
{
- ResourceUri _elem422; // required
+ ResourceUri _elem422; // optional
_elem422 = new ResourceUri();
_elem422.read(iprot);
struct.resourceUris.add(_elem422);
@@ -1180,7 +1180,7 @@ public class Function implements org.apa
struct.resourceUris = new ArrayList<ResourceUri>(_list425.size);
for (int _i426 = 0; _i426 < _list425.size; ++_i426)
{
- ResourceUri _elem427; // required
+ ResourceUri _elem427; // optional
_elem427 = new ResourceUri();
_elem427.read(iprot);
struct.resourceUris.add(_elem427);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java Wed Apr 15 01:11:47 2015
@@ -447,7 +447,7 @@ public class GetOpenTxnsInfoResponse imp
struct.open_txns = new ArrayList<TxnInfo>(_list428.size);
for (int _i429 = 0; _i429 < _list428.size; ++_i429)
{
- TxnInfo _elem430; // required
+ TxnInfo _elem430; // optional
_elem430 = new TxnInfo();
_elem430.read(iprot);
struct.open_txns.add(_elem430);
@@ -524,7 +524,7 @@ public class GetOpenTxnsInfoResponse imp
struct.open_txns = new ArrayList<TxnInfo>(_list433.size);
for (int _i434 = 0; _i434 < _list433.size; ++_i434)
{
- TxnInfo _elem435; // required
+ TxnInfo _elem435; // optional
_elem435 = new TxnInfo();
_elem435.read(iprot);
struct.open_txns.add(_elem435);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java Wed Apr 15 01:11:47 2015
@@ -447,7 +447,7 @@ public class GetOpenTxnsResponse impleme
struct.open_txns = new HashSet<Long>(2*_set436.size);
for (int _i437 = 0; _i437 < _set436.size; ++_i437)
{
- long _elem438; // required
+ long _elem438; // optional
_elem438 = iprot.readI64();
struct.open_txns.add(_elem438);
}
@@ -523,7 +523,7 @@ public class GetOpenTxnsResponse impleme
struct.open_txns = new HashSet<Long>(2*_set441.size);
for (int _i442 = 0; _i442 < _set441.size; ++_i442)
{
- long _elem443; // required
+ long _elem443; // optional
_elem443 = iprot.readI64();
struct.open_txns.add(_elem443);
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetPrincipalsInRoleResponse.java Wed Apr 15 01:11:47 2015
@@ -354,7 +354,7 @@ public class GetPrincipalsInRoleResponse
struct.principalGrants = new ArrayList<RolePrincipalGrant>(_list86.size);
for (int _i87 = 0; _i87 < _list86.size; ++_i87)
{
- RolePrincipalGrant _elem88; // required
+ RolePrincipalGrant _elem88; // optional
_elem88 = new RolePrincipalGrant();
_elem88.read(iprot);
struct.principalGrants.add(_elem88);
@@ -425,7 +425,7 @@ public class GetPrincipalsInRoleResponse
struct.principalGrants = new ArrayList<RolePrincipalGrant>(_list91.size);
for (int _i92 = 0; _i92 < _list91.size; ++_i92)
{
- RolePrincipalGrant _elem93; // required
+ RolePrincipalGrant _elem93; // optional
_elem93 = new RolePrincipalGrant();
_elem93.read(iprot);
struct.principalGrants.add(_elem93);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetRoleGrantsForPrincipalResponse.java Wed Apr 15 01:11:47 2015
@@ -354,7 +354,7 @@ public class GetRoleGrantsForPrincipalRe
struct.principalGrants = new ArrayList<RolePrincipalGrant>(_list78.size);
for (int _i79 = 0; _i79 < _list78.size; ++_i79)
{
- RolePrincipalGrant _elem80; // required
+ RolePrincipalGrant _elem80; // optional
_elem80 = new RolePrincipalGrant();
_elem80.read(iprot);
struct.principalGrants.add(_elem80);
@@ -425,7 +425,7 @@ public class GetRoleGrantsForPrincipalRe
struct.principalGrants = new ArrayList<RolePrincipalGrant>(_list83.size);
for (int _i84 = 0; _i84 < _list83.size; ++_i84)
{
- RolePrincipalGrant _elem85; // required
+ RolePrincipalGrant _elem85; // optional
_elem85 = new RolePrincipalGrant();
_elem85.read(iprot);
struct.principalGrants.add(_elem85);
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java Wed Apr 15 01:11:47 2015
@@ -459,7 +459,7 @@ public class HeartbeatTxnRangeResponse i
struct.aborted = new HashSet<Long>(2*_set468.size);
for (int _i469 = 0; _i469 < _set468.size; ++_i469)
{
- long _elem470; // required
+ long _elem470; // optional
_elem470 = iprot.readI64();
struct.aborted.add(_elem470);
}
@@ -477,7 +477,7 @@ public class HeartbeatTxnRangeResponse i
struct.nosuch = new HashSet<Long>(2*_set471.size);
for (int _i472 = 0; _i472 < _set471.size; ++_i472)
{
- long _elem473; // required
+ long _elem473; // optional
_elem473 = iprot.readI64();
struct.nosuch.add(_elem473);
}
@@ -566,7 +566,7 @@ public class HeartbeatTxnRangeResponse i
struct.aborted = new HashSet<Long>(2*_set478.size);
for (int _i479 = 0; _i479 < _set478.size; ++_i479)
{
- long _elem480; // required
+ long _elem480; // optional
_elem480 = iprot.readI64();
struct.aborted.add(_elem480);
}
@@ -577,7 +577,7 @@ public class HeartbeatTxnRangeResponse i
struct.nosuch = new HashSet<Long>(2*_set481.size);
for (int _i482 = 0; _i482 < _set481.size; ++_i482)
{
- long _elem483; // required
+ long _elem483; // optional
_elem483 = iprot.readI64();
struct.nosuch.add(_elem483);
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HiveObjectRef.java Wed Apr 15 01:11:47 2015
@@ -710,7 +710,7 @@ public class HiveObjectRef implements or
struct.partValues = new ArrayList<String>(_list8.size);
for (int _i9 = 0; _i9 < _list8.size; ++_i9)
{
- String _elem10; // required
+ String _elem10; // optional
_elem10 = iprot.readString();
struct.partValues.add(_elem10);
}
@@ -853,7 +853,7 @@ public class HiveObjectRef implements or
struct.partValues = new ArrayList<String>(_list13.size);
for (int _i14 = 0; _i14 < _list13.size; ++_i14)
{
- String _elem15; // required
+ String _elem15; // optional
_elem15 = iprot.readString();
struct.partValues.add(_elem15);
}
Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java?rev=1673599&r1=1673598&r2=1673599&view=diff
==============================================================================
--- hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java (original)
+++ hive/branches/cbo/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java Wed Apr 15 01:11:47 2015
@@ -354,7 +354,7 @@ public class InsertEventRequestData impl
struct.filesAdded = new ArrayList<String>(_list508.size);
for (int _i509 = 0; _i509 < _list508.size; ++_i509)
{
- String _elem510; // required
+ String _elem510; // optional
_elem510 = iprot.readString();
struct.filesAdded.add(_elem510);
}
@@ -424,7 +424,7 @@ public class InsertEventRequestData impl
struct.filesAdded = new ArrayList<String>(_list513.size);
for (int _i514 = 0; _i514 < _list513.size; ++_i514)
{
- String _elem515; // required
+ String _elem515; // optional
_elem515 = iprot.readString();
struct.filesAdded.add(_elem515);
}