You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by dh...@apache.org on 2008/11/11 02:50:18 UTC
svn commit: r712905 [1/38] - in /hadoop/core/trunk: ./ src/contrib/hive/
src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/
src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/
src/contrib/hive/conf/ src/contrib/hive/data/files/ src/con...
Author: dhruba
Date: Mon Nov 10 17:50:06 2008
New Revision: 712905
URL: http://svn.apache.org/viewvc?rev=712905&view=rev
Log:
HADOOP-4566. Deploy new hive code to support more types.
(Zheng Shao via dhruba)
Added:
hadoop/core/trunk/src/contrib/hive/data/files/apache.access.log
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/Throttle.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/io/FlatFileInputFormat.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/optimizer/
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPruner.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Optimizer.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/optimizer/Transform.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/OpParseContext.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/ParseContext.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/io/
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/io/JavaTestObjFlatFileInputFormat.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/io/RecordTestObj.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/io/TestFlatFileInputFormat.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/bad_sample_clause.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/input1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/input2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/input_testxpath4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/invalid_create_tbl1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/invalid_tbl_name.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/joinneg.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/load_wrong_fileformat.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/notable_alias3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientnegative/notable_alias4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/alter1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby1_map.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby2_map.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby3_map.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby4_map.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby5_map.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input0.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input17.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input18.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input19.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part0.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join10.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join11.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join12.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join13.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join14.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join15.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join16.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/noalias_subq1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/notable_alias1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/notable_alias2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/quote1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/scriptfile1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/insert_wrong_number_columns.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/bad_sample_clause.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/input1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/input2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/input_testxpath4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/invalid_create_tbl1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/invalid_tbl_name.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/joinneg.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/load_wrong_fileformat.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/notable_alias3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientnegative/notable_alias4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/alter1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby1_map.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby2_map.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby3_map.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby4_map.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby5_map.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input0.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input17.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input18.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input19.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part0.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl8.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join10.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join11.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join12.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join13.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join14.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join15.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join16.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/noalias_subq1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/notable_alias1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/notable_alias2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/quote1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/scriptfile1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/errors/insert_wrong_number_columns.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/scripts/
hadoop/core/trunk/src/contrib/hive/ql/src/test/scripts/testgrep
hadoop/core/trunk/src/contrib/hive/serde/README
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeAsync.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeCommaOrSemicolon.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConst.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstListContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstMap.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstMapContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeDefinitionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnum.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeExtends.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldRequiredness.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFlagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFunctionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeHeader.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeHeaderList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeInclude.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeNamespace.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenum.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeService.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeStart.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeThrows.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeUnflagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeXception.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/JJTthrift_grammarState.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/Node.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/ParseException.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/SimpleCharStream.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/SimpleNode.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/Token.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/TokenMgrError.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammar.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammar.jj
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarTokenManager.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarTreeConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/thrift/SkippableTProtocol.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/thrift/TBinarySortableProtocol.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/thrift/WriteNullsProtocol.java
Removed:
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/OperatorInfo.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/notable_alias1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/notable_alias2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/notable_alias3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/wrong_distinct3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/errors/notable_alias1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/errors/notable_alias2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/errors/notable_alias3.q.out
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeAsync.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeCommaOrSemicolon.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConst.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConstList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConstListContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConstMap.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConstMapContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeConstValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeDefinitionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeEnum.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeEnumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeEnumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeExtends.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFieldRequiredness.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFieldValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFlagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFunctionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeHeader.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeHeaderList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeInclude.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeNamespace.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeSenum.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeSenumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeSenumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeService.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeStart.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeThrows.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeUnflagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeXception.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/JJTthrift_grammarState.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/Node.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/ParseException.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/SimpleCharStream.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/SimpleNode.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/Token.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/TokenMgrError.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammar.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammar.jj
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammar.jjt
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammarConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammarTokenManager.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammarTreeConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeAsync.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeCommaOrSemicolon.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConst.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstListContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstMap.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstMapContents.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeConstValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeDefinitionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnum.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeEnumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeExtends.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldRequiredness.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldValue.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFlagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFunctionType.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeHeader.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeHeaderList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeInclude.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeNamespace.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenum.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenumDef.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeSenumDefList.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeService.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeStart.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeThrows.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeDefinition.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeUnflagArgs.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeXception.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/JJTthrift_grammarState.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/Node.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/ParseException.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/SimpleCharStream.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/SimpleNode.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/Token.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/TokenMgrError.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammar.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammar.jj
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarTokenManager.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammarTreeConstants.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDe.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeField.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFieldList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFieldType.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeFunction.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeHiveField.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeSimpleNode.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeStruct.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeStructBase.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeBase.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeBool.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeByte.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeContainer.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeDouble.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeMap.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeSet.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypeString.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypedef.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypei16.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypei32.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/DynamicSerDeTypei64.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/dynamic_type/thrift_grammar.jjt
Modified:
hadoop/core/trunk/CHANGES.txt
hadoop/core/trunk/src/contrib/hive/README
hadoop/core/trunk/src/contrib/hive/build.xml
hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/SetProcessor.java
hadoop/core/trunk/src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
hadoop/core/trunk/src/contrib/hive/conf/hive-default.xml
hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java
hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java
hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestPartitions.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecDriver.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ExecReducer.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ExprNodeFuncEvaluator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ExtractOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/FilterOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/GroupByOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/JoinOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/LimitOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/MapRedTask.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/MoveTask.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/OperatorFactory.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ReduceSinkOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/SelectOperator.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/metadata/Partition.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/metadata/Table.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/BaseSemanticAnalyzer.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/ErrorMsg.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/Hive.g
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/PartitionPruner.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/QB.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/QBJoinTree.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/QBMetaData.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/QBParseInfo.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/SamplePruner.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzerFactory.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/parse/TableSample.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/PlanUtils.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/alterTableDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/exprNodeColumnDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/exprNodeDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/exprNodeFieldDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/exprNodeFuncDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/exprNodeIndexDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/fetchWork.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/groupByDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/mapredWork.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/reduceSinkDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/plan/selectDesc.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/session/SessionState.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/typeinfo/PrimitiveTypeInfo.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/typeinfo/TypeInfoUtils.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDAFAvg.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDAFCount.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDAFMax.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDAFMin.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDAFSum.java
hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/udf/UDFToString.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/QTestUtil.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/org/apache/hadoop/hive/ql/exec/TestExecDriver.java
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/case_sensitivity.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/cast1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby1_limit.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/groupby8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input10.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input11.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input11_limit.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input12.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input13.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input14.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input14_limit.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input15.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input16.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input16_cc.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input1_limit.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input4_cb_delim.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input9.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_dfs.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_dynamicserde.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_part2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_testxpath.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/input_testxpath2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/inputddl6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/join9.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/sample7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/show_tables.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/udf1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/udf2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/udf3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/clientpositive/udf4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/negative/quoted_string.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/cast1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/groupby2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/groupby3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/groupby4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/groupby5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/groupby6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input3.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input_part1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input_testxpath.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/input_testxpath2.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/join4.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/join5.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/join6.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/join7.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/join8.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/sample1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/queries/positive/udf1.q
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/case_sensitivity.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/cast1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby1_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby2_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/groupby6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input11.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input11_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input12.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input13.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input14.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input14_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input15.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input1_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input2_limit.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input8.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input9.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_dynamicserde.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_part2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_testxpath.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_testxpath2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/input_testxpath3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/inputddl6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join8.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/join9.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/sample7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/subq.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/subq2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/udf1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/udf3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/udf4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/clientpositive/union.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/errors/quoted_string.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/cast1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/groupby2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/groupby3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/groupby4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/groupby5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/groupby6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input8.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input_part1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input_testxpath.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/input_testxpath2.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/join4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/join5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/join6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/join7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/join8.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample3.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample4.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample5.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample6.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/sample7.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/parse/udf1.q.out
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/case_sensitivity.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/cast1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby2.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby3.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby4.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby5.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/groupby6.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input2.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input3.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input4.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input5.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input6.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input7.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input8.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input9.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input_part1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input_testsequencefile.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input_testxpath.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/input_testxpath2.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join2.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join3.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join4.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join5.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join6.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join7.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/join8.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample2.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample3.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample4.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample5.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample6.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/sample7.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/subq.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/udf1.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/udf4.q.xml
hadoop/core/trunk/src/contrib/hive/ql/src/test/results/compiler/plan/union.q.xml
hadoop/core/trunk/src/contrib/hive/serde/build.xml
hadoop/core/trunk/src/contrib/hive/serde/if/serde.thrift
hadoop/core/trunk/src/contrib/hive/serde/src/gen-java/org/apache/hadoop/hive/serde/Constants.java
hadoop/core/trunk/src/contrib/hive/serde/src/gen-php/serde_constants.php
hadoop/core/trunk/src/contrib/hive/serde/src/gen-py/org_apache_hadoop_hive_serde/constants.py
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/SerDeUtils.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde/simple_meta/MetadataTypedColumnsetSerDe.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/MetadataTypedColumnsetSerDe.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/SerDeUtils.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDe.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeField.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeFieldType.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeStructBase.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeBase.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeBool.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeByte.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeDouble.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeList.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeMap.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeSet.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypeString.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypei16.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypei32.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/DynamicSerDeTypei64.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/dynamic_type/thrift_grammar.jjt
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/ObjectInspectorUtils.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/StandardPrimitiveObjectInspector.java
hadoop/core/trunk/src/contrib/hive/serde/src/java/org/apache/hadoop/hive/serde2/thrift/TCTLSeparatedProtocol.java
hadoop/core/trunk/src/contrib/hive/serde/src/test/org/apache/hadoop/hive/serde2/TestTCTLSeparatedProtocol.java
hadoop/core/trunk/src/contrib/hive/serde/src/test/org/apache/hadoop/hive/serde2/dynamic_type/TestDynamicSerDe.java
hadoop/core/trunk/src/contrib/hive/serde/src/test/org/apache/hadoop/hive/serde2/objectinspector/TestStandardObjectInspectors.java
Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Mon Nov 10 17:50:06 2008
@@ -110,6 +110,9 @@
HADOOP-4621. Fix javadoc warnings caused by duplicate jars. (Kan Zhang via
cdouglas)
+ HADOOP-4566. Deploy new hive code to support more types.
+ (Zheng Shao via dhruba)
+
Release 0.19.0 - Unreleased
INCOMPATIBLE CHANGES
Modified: hadoop/core/trunk/src/contrib/hive/README
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/README?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/README (original)
+++ hadoop/core/trunk/src/contrib/hive/README Mon Nov 10 17:50:06 2008
@@ -118,6 +118,10 @@
shows the list of columns
+hive> DESCRIBE EXTENDED invites;
+
+shows the list of columns plus any other meta information about the table
+
Altering tables. Table name can be changed and additional columns can be dropped
hive> ALTER TABLE pokes ADD COLUMNS (new_col INT);
@@ -258,28 +262,92 @@
STREAMING
---------
-hive> FROM invites a INSERT OVERWRITE TABLE events SELECT TRANSFORM(a.foo, a.bar) AS (oof, rab) USING '/bin/cat' WHERE a.ds > '2008-08-09';
+hive> FROM invites a INSERT OVERWRITE TABLE events
+ > SELECT TRANSFORM(a.foo, a.bar) AS (oof, rab)
+ > USING '/bin/cat' WHERE a.ds > '2008-08-09';
-This streams the data in the map phase through the script /bin/cat (like hadoop streaming).
+This streams the data in the map phase through the script /bin/cat (like hadoop streaming).
Similarly - streaming can be used on the reduce side (please see the Hive Tutorial or examples)
KNOWN BUGS/ISSUES
-----------------
* hive cli may hang for a couple of minutes because of a bug in getting metadata
from the derby database. let it run and you'll be fine!
-* hive cli does not support multi-line queries.
* hive cli creates derby.log in the directory from which it has been invoked.
-* DESCRIBE table currently only shows columns in a table. Other metadata like
- partitions, buckets etc are not shown.
-* LOAD FILE or INSERT INTO TABLE do not validate schemas of the destination tables.
* COUNT(*) does not work for now. Use COUNT(1) instead.
-* String literals are indicated by single quotes(double quotes are not supported).
- So 'is a valid string' while "is not a valid string" in the query language. Hive
- does support escaping quotes and semi-colon similar to MySQL.
-* Multiple GROUP BYs are not supported in the multi-table table INSERT queries.
-* ORDER BY not supported.
+* ORDER BY not supported yet.
* Only string and thrift types (http://developers.facebook.com/thrift) have been tested.
-
+* When doing Join, please put the table with big number of rows containing the same join key to
+the rightmost in the JOIN clause. Otherwise we may see OutOfMemory errors.
FUTURE FEATURES
---------------
+* EXPLODE function to generate multiple rows from a column of list type.
+* Simpler syntax for running Map/Reduce scripts.
+* ORDER BY and SORT BY.
+* Table statistics for query optimization.
+
+Developing Hive using Eclipse
+------------------------
+1. Set up hadoop development environment with Eclipse:
+http://wiki.apache.org/hadoop/EclipseEnvironment
+
+2. Download Hive src code from:
+http://mirror.facebook.com/facebook/hive
+
+If hadoop version is 0.17.x or 0.18.x, use
+http://mirror.facebook.com/facebook/hive/hadoop-0.17/
+
+If hadoop version is 0.19.x or up or trunk, use
+http://mirror.facebook.com/facebook/hive/hadoop-0.19/
+
+3. Extract the Hive src code to src/contrib/hive, make sure this file (README)
+ is in src/contrib/hive.
+
+4. In src/contrib/hive, run "ant package"
+
+5. In src/contrib/hive, run "ant -logfile test.log test" to make sure
+ everything works. This test may take 20 minutes.
+
+6. Add the following list to the Eclipse project's .classpath file:
+ <classpathentry kind="src" path="build/contrib/hive/ql/test/src"/>
+ <classpathentry kind="src" path="build/contrib/hive/ql/gen-java"/>
+ <classpathentry kind="src" path="src/contrib/hive/cli/src/java"/>
+ <classpathentry kind="src" path="src/contrib/hive/common/src/java"/>
+ <classpathentry kind="src" path="src/contrib/hive/metastore/src/model"/>
+ <classpathentry kind="src" path="src/contrib/hive/metastore/src/gen-javabean"/>
+ <classpathentry kind="src" path="src/contrib/hive/metastore/src/java"/>
+ <classpathentry kind="src" path="src/contrib/hive/metastore/src/test"/>
+ <classpathentry kind="src" path="src/contrib/hive/ql/src/java"/>
+ <classpathentry kind="src" path="src/contrib/hive/ql/src/test"/>
+ <classpathentry kind="src" path="src/contrib/hive/serde/src/gen-java"/>
+ <classpathentry kind="src" path="src/contrib/hive/serde/src/java"/>
+ <classpathentry kind="src" path="src/contrib/hive/serde/src/test"/>
+ <classpathentry kind="lib" path="src/contrib/hive/cli/lib/jline-0.9.94.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/asm-3.1.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/commons-lang-2.4.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/derby.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/jdo2-api-2.1.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/jpox-core-1.2.2.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/jpox-enhancer-1.2.2.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/jpox-rdbms-1.2.2.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/libfb303.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/lib/libthrift.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/ql/lib/antlr-3.0.1.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/ql/lib/antlr-runtime-3.0.1.jar"/>
+ <classpathentry kind="lib" path="src/contrib/hive/ql/lib/commons-jexl-1.1.jar"/>
+ <classpathentry kind="lib" path="build/contrib/hive/metastore/metastore_model.jar" sourcepath="src/contrib/hive/metastore/src/model"/>
+
+7. Develop using Eclipse.
+
+
+Development Tips
+------------------------
+* You may change the first line in conf/hive-log4j.properties to the following line to see error messages on the console.
+hive.root.logger=INFO,console
+Otherwise you will see error messages in /tmp/<username>
+* You may use the following line to test a specific testcase with a specific query file.
+ant -Dtestcase=TestParse -Dqfile=udf4.q test
+ant -Dtestcase=TestParseNegative -Dqfile=invalid_dot.q test
+ant -Dtestcase=TestCliDriver -Dqfile=udf1.q test
+ant -Dtestcase=TestNegativeCliDriver -Dqfile=invalid_tbl_name.q test
Modified: hadoop/core/trunk/src/contrib/hive/build.xml
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/build.xml?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/build.xml (original)
+++ hadoop/core/trunk/src/contrib/hive/build.xml Mon Nov 10 17:50:06 2008
@@ -161,10 +161,6 @@
<copy todir="${target.example.dir}/queries" preservelastmodified="true" flatten="true">
<fileset dir="${ql.test.query.dir}/positive" includes="*.q"/>
</copy>
- <mkdir dir="${dist.dir}/contrib/hive"/>
- <copy todir="${dist.dir}/contrib/hive">
- <fileset dir="${target.dir}"/>
- </copy>
</target>
</project>
Modified: hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java (original)
+++ hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java Mon Nov 10 17:50:06 2008
@@ -31,6 +31,7 @@
import org.apache.hadoop.hive.ql.Driver;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.commons.lang.StringUtils;
import org.apache.hadoop.hive.ql.session.SessionState.LogHelper;
public class CliDriver {
@@ -41,7 +42,18 @@
public static SetProcessor sp;
public static Driver qp;
public static FsShell dfs;
+ public static Log LOG = LogFactory.getLog("CliDriver");
+ /**
+ * delay console initialization until session has been initialized
+ */
+ public static LogHelper console;
+ public static LogHelper getConsole() {
+ if(console == null)
+ console = new LogHelper(LOG);
+ return (console);
+ }
+
public CliDriver(CliSessionState ss) {
SessionState.start(ss);
sp = new SetProcessor();
@@ -49,23 +61,28 @@
}
public static int processCmd(String cmd) {
+
+ SessionState ss = SessionState.get();
+ LogHelper console = getConsole();
+
String[] tokens = cmd.split("\\s+");
String cmd_1 = cmd.substring(tokens[0].length());
int ret = 0;
- if(tokens[0].equals("set")) {
+ if(tokens[0].toLowerCase().equals("set")) {
+
ret = sp.run(cmd_1);
- } else if (cmd.equals("quit") || cmd.equals("exit")) {
+
+ } else if (cmd.toLowerCase().equals("quit") || cmd.toLowerCase().equals("exit")) {
+
// if we have come this far - either the previous commands
// are all successful or this is command line. in either case
// this counts as a successful run
System.exit(0);
+
} else if (cmd.startsWith("!")) {
- SessionState ss = SessionState.get();
+
String shell_cmd = cmd.substring(1);
- if (shell_cmd.endsWith(";")) {
- shell_cmd = shell_cmd.substring(0, shell_cmd.length()-1);
- }
//shell_cmd = "/bin/bash -c \'" + shell_cmd + "\'";
try {
@@ -76,48 +93,102 @@
outPrinter.start();
errPrinter.start();
- int exitVal = executor.waitFor();
- if (exitVal != 0) {
- ss.err.write((new String("Command failed with exit code = " + exitVal)).getBytes());
+ ret = executor.waitFor();
+ if (ret != 0) {
+ console.printError("Command failed with exit code = " + ret);
}
}
catch (Exception e) {
- e.printStackTrace();
+ console.printError("Exception raised from Shell command " + e.getLocalizedMessage(),
+ org.apache.hadoop.util.StringUtils.stringifyException(e));
+ ret = 1;
}
- } else if (cmd.startsWith("dfs")) {
+
+ } else if (tokens[0].toLowerCase().equals("dfs")) {
+
// dfs shell commands
- SessionState ss = SessionState.get();
if(dfs == null)
dfs = new FsShell(ss.getConf());
- String hadoopCmd = cmd.replaceFirst("dfs\\s+", "");
- hadoopCmd = hadoopCmd.trim();
- if (hadoopCmd.endsWith(";")) {
- hadoopCmd = hadoopCmd.substring(0, hadoopCmd.length()-1);
- }
- String[] args = hadoopCmd.split("\\s+");
+
+ String [] alt_tokens = new String [tokens.length-1];
+ System.arraycopy(tokens, 1, alt_tokens, 0, tokens.length-1);
+ tokens = alt_tokens;
+
try {
PrintStream oldOut = System.out;
System.setOut(ss.out);
- int val = dfs.run(args);
+ ret = dfs.run(tokens);
System.setOut(oldOut);
- if (val != 0) {
- ss.err.write((new String("Command failed with exit code = " + val)).getBytes());
+ if (ret != 0) {
+ console.printError("Command failed with exit code = " + ret);
}
} catch (Exception e) {
- ss.err.println("Exception raised from DFSShell.run " + e.getLocalizedMessage());
+ console.printError("Exception raised from DFSShell.run " + e.getLocalizedMessage(),
+ org.apache.hadoop.util.StringUtils.stringifyException(e));
+ ret = 1;
+ }
+
+ } else if (tokens[0].toLowerCase().equals("list")) {
+
+ SessionState.ResourceType t;
+ if(tokens.length < 2 || (t = SessionState.find_resource_type(tokens[1])) == null) {
+ console.printError("Usage: list [" +
+ StringUtils.join(SessionState.ResourceType.values(),"|") +
+ "] [<value> [<value>]*]" );
+ ret = 1;
+ } else {
+ List<String> filter = null;
+ if(tokens.length >=3) {
+ System.arraycopy(tokens, 2, tokens, 0, tokens.length-2);
+ filter = Arrays.asList(tokens);
+ }
+ Set<String> s = ss.list_resource(t, filter);
+ if(s != null && !s.isEmpty())
+ ss.out.println(StringUtils.join(s, "\n"));
}
+
+ } else if (tokens[0].toLowerCase().equals("add")) {
+
+ SessionState.ResourceType t;
+ if(tokens.length < 3 || (t = SessionState.find_resource_type(tokens[1])) == null) {
+ console.printError("Usage: add [" +
+ StringUtils.join(SessionState.ResourceType.values(),"|") +
+ "] <value> [<value>]*");
+ ret = 1;
+ } else {
+ for(int i = 2; i<tokens.length; i++) {
+ ss.add_resource(t, tokens[i]);
+ }
+ }
+
+ } else if (tokens[0].toLowerCase().equals("delete")) {
+
+ SessionState.ResourceType t;
+ if(tokens.length < 2 || (t = SessionState.find_resource_type(tokens[1])) == null) {
+ console.printError("Usage: delete [" +
+ StringUtils.join(SessionState.ResourceType.values(),"|") +
+ "] [<value>]");
+ ret = 1;
+ } else if (tokens.length >= 3) {
+ for(int i = 2; i<tokens.length; i++) {
+ ss.delete_resource(t, tokens[i]);
+ }
+ } else {
+ ss.delete_resource(t);
+ }
+
} else {
+ PrintStream out = ss.out;
+
ret = qp.run(cmd);
Vector<String> res = new Vector<String>();
while (qp.getResults(res)) {
for (String r:res) {
- SessionState ss = SessionState.get();
- PrintStream out = ss.out;
out.println(r);
}
res.clear();
}
-
+
int cret = qp.close();
if (ret == 0) {
ret = cret;
@@ -223,8 +294,7 @@
String historyFile = System.getProperty("user.home") + File.separator + HISTORYFILE;
reader.setHistory(new History(new File(historyFile)));
int ret = 0;
- Log LOG = LogFactory.getLog("CliDriver");
- LogHelper console = new LogHelper(LOG);
+
String prefix = "";
String curPrompt = prompt;
while ((line = reader.readLine(curPrompt+"> ")) != null) {
@@ -242,10 +312,11 @@
long end = System.currentTimeMillis();
if (end > start) {
double timeTaken = (double)(end-start)/1000.0;
- console.printInfo("Time taken: " + timeTaken + " seconds", null);
+ getConsole().printInfo("Time taken: " + timeTaken + " seconds", null);
}
}
System.exit(ret);
}
+
}
Modified: hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/SetProcessor.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/SetProcessor.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/SetProcessor.java (original)
+++ hadoop/core/trunk/src/contrib/hive/cli/src/java/org/apache/hadoop/hive/cli/SetProcessor.java Mon Nov 10 17:50:06 2008
@@ -81,8 +81,8 @@
part[0] = nwcmd.substring(0, nwcmd.length()-1);
part[1] = "";
} else {
- part[0] = nwcmd.substring(0, eqIndex);
- part[1] = nwcmd.substring(eqIndex+1);
+ part[0] = nwcmd.substring(0, eqIndex).trim();
+ part[1] = nwcmd.substring(eqIndex+1).trim();
}
try {
Modified: hadoop/core/trunk/src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java (original)
+++ hadoop/core/trunk/src/contrib/hive/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java Mon Nov 10 17:50:06 2008
@@ -81,7 +81,13 @@
HIVETABLENAME("hive.table.name", ""),
HIVEPARTITIONNAME("hive.partition.name", ""),
HIVEPARTITIONPRUNER("hive.partition.pruning", "nonstrict"),
- HIVEALIAS("hive.alias", "");
+ HIVEALIAS("hive.alias", ""),
+ HIVEMAPSIDEAGGREGATE("hive.map.aggr", "false"),
+ HIVEJOINEMITINTERVAL("hive.join.emit.interval", 1000),
+
+ // Default file format for CREATE TABLE statement
+ // Options: TextFile, SequenceFile
+ HIVEDEFAULTFILEFORMAT("hive.default.fileformat", "TextFile");
public final String varname;
public final String defaultVal;
Modified: hadoop/core/trunk/src/contrib/hive/conf/hive-default.xml
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/conf/hive-default.xml?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/conf/hive-default.xml (original)
+++ hadoop/core/trunk/src/contrib/hive/conf/hive-default.xml Mon Nov 10 17:50:06 2008
@@ -84,4 +84,22 @@
<description>Name of the class that implements org.apache.hadoop.hive.metastore.rawstore interface. This class is used to store and retrieval of raw metadata objects such as table, database</description>
</property>
+<property>
+ <name>hive.default.fileformat</name>
+ <value>TextFile</value>
+ <description>Default file format for CREATE TABLE statement. Options are TextFile and SequenceFile. Users can explicitly say CREATE TABLE ... STORED AS <TEXTFILE|SEQUENCEFILE> to override</description>
+</property>
+
+<property>
+ <name>hive.map.aggr</name>
+ <value>false</value>
+ <description>Whether to use map-side aggregation in Hive Group By queries</description>
+</property>
+
+<property>
+ <name>hive.join.emit.interval</name>
+ <value>1000</value>
+ <description>How many rows in the right-most join operand Hive should buffer before emitting the join result. </description>
+</property>
+
</configuration>
Added: hadoop/core/trunk/src/contrib/hive/data/files/apache.access.log
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/data/files/apache.access.log?rev=712905&view=auto
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/data/files/apache.access.log (added)
+++ hadoop/core/trunk/src/contrib/hive/data/files/apache.access.log Mon Nov 10 17:50:06 2008
@@ -0,0 +1 @@
+127.0.0.1 - frank [10/Oct/2000:13:55:36 -0700] "GET /apache_pb.gif HTTP/1.0" 200 2326
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java Mon Nov 10 17:50:06 2008
@@ -271,8 +271,10 @@
this.incrementCounter("create_table");
logStartFunction("create_table: db=" + tbl.getDbName() + " tbl=" + tbl.getTableName());
boolean success = false;
- if(!MetaStoreUtils.validateName(tbl.getTableName())) {
- throw new InvalidObjectException(tbl.getTableName() + " is not a valid object name");
+ if(!MetaStoreUtils.validateName(tbl.getTableName()) ||
+ !MetaStoreUtils.validateColNames(tbl.getSd().getCols()) ||
+ (tbl.getPartitionKeys() != null && !MetaStoreUtils.validateColNames(tbl.getPartitionKeys()))) {
+ throw new InvalidObjectException(tbl.getTableName() + " is not a valid object name");
}
try {
getMS().openTransaction();
@@ -540,11 +542,15 @@
logStartFunction("getVersion");
return "3.0";
}
-
+
public void alter_table(String dbname, String name, Table newTable) throws InvalidOperationException,
MetaException {
this.incrementCounter("alter_table");
logStartFunction("truncate_table: db=" + dbname + " tbl=" + name + " newtbl=" + newTable.getTableName());
+ if(!MetaStoreUtils.validateName(newTable.getTableName()) ||
+ !MetaStoreUtils.validateColNames(newTable.getSd().getCols())) {
+ throw new InvalidOperationException(newTable.getTableName() + " is not a valid object name");
+ }
try {
getMS().alterTable(dbname, name, newTable);
} catch (InvalidObjectException e) {
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java Mon Nov 10 17:50:06 2008
@@ -231,8 +231,8 @@
/**
* validateName
*
- * Checks the name conforms to our standars which are: "[a-zA-z-_0-9]+".
- * checks this is just characters and numbers and _ and . and -
+ * Checks the name conforms to our standars which are: "[a-zA-z_0-9]+".
+ * checks this is just characters and numbers and _
*
* @param tableName the name to validate
* @return none
@@ -246,6 +246,14 @@
}
return false;
}
+
+ static public boolean validateColNames(List<FieldSchema> cols) {
+ for (FieldSchema fieldSchema : cols) {
+ if(!validateName(fieldSchema.getName()))
+ return false;
+ }
+ return true;
+ }
/**
* Change from old to new format properties of a schema file
@@ -395,7 +403,9 @@
static HashMap<String, String> typeToThriftTypeMap;
static {
typeToThriftTypeMap = new HashMap<String, String>();
+ typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.BOOLEAN_TYPE_NAME, "bool");
typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.TINYINT_TYPE_NAME, "byte");
+ typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.SMALLINT_TYPE_NAME, "i16");
typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.INT_TYPE_NAME, "i32");
typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.BIGINT_TYPE_NAME, "i64");
typeToThriftTypeMap.put(org.apache.hadoop.hive.serde.Constants.DOUBLE_TYPE_NAME, "double");
@@ -446,7 +456,7 @@
ddl.append(col.getName());
}
ddl.append("}");
- LOG.warn("DDL: " + ddl);
+ LOG.info("DDL: " + ddl);
return ddl.toString();
}
public static Properties getSchema(org.apache.hadoop.hive.metastore.api.Table tbl) {
@@ -538,7 +548,7 @@
* @throws SerDeException
* @throws MetaException
*/
- static List<FieldSchema> getFieldsFromDeserializer(String tableName, Deserializer deserializer) throws SerDeException, MetaException {
+ public static List<FieldSchema> getFieldsFromDeserializer(String tableName, Deserializer deserializer) throws SerDeException, MetaException {
ObjectInspector oi = deserializer.getObjectInspector();
String [] names = tableName.split("\\.");
String last_name = names[names.length-1];
@@ -572,4 +582,5 @@
}
return str_fields;
}
+
}
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestHiveMetaStore.java Mon Nov 10 17:50:06 2008
@@ -28,6 +28,8 @@
import org.apache.hadoop.hive.serde.Constants;
import org.apache.hadoop.hive.metastore.api.Database;
import org.apache.hadoop.hive.metastore.api.FieldSchema;
+import org.apache.hadoop.hive.metastore.api.InvalidObjectException;
+import org.apache.hadoop.hive.metastore.api.InvalidOperationException;
import org.apache.hadoop.hive.metastore.api.Order;
import org.apache.hadoop.hive.metastore.api.Partition;
import org.apache.hadoop.hive.metastore.api.SerDeInfo;
@@ -350,6 +352,81 @@
}
}
+ public void testAlterTable() throws Exception {
+ try {
+ String dbName = "alterdb";
+ String invTblName = "alter-tbl";
+ String tblName = "altertbl";
+
+ client.dropTable(dbName, tblName);
+ client.dropDatabase(dbName);
+ boolean ret = client.createDatabase(dbName, "strange_loc");
+ assertTrue("Unable to create the databse " + dbName, ret);
+
+ ArrayList<FieldSchema> invCols = new ArrayList<FieldSchema>(2);
+ invCols.add(new FieldSchema("n-ame", Constants.STRING_TYPE_NAME, ""));
+ invCols.add(new FieldSchema("in.come", Constants.INT_TYPE_NAME, ""));
+
+ Table tbl = new Table();
+ tbl.setDbName(dbName);
+ tbl.setTableName(invTblName);
+ StorageDescriptor sd = new StorageDescriptor();
+ tbl.setSd(sd);
+ sd.setCols(invCols);
+ sd.setCompressed(false);
+ sd.setNumBuckets(1);
+ sd.setParameters(new HashMap<String, String>());
+ sd.getParameters().put("test_param_1", "Use this for comments etc");
+ sd.setBucketCols(new ArrayList<String>(2));
+ sd.getBucketCols().add("name");
+ sd.setSerdeInfo(new SerDeInfo());
+ sd.getSerdeInfo().setName(tbl.getTableName());
+ sd.getSerdeInfo().setParameters(new HashMap<String, String>());
+ sd.getSerdeInfo().getParameters().put(org.apache.hadoop.hive.serde.Constants.SERIALIZATION_FORMAT, "1");
+ boolean failed = false;
+ try {
+ client.createTable(tbl);
+ } catch (InvalidObjectException ex) {
+ failed = true;
+ }
+ if(!failed) {
+ assertTrue("Able to create table with invalid name: " + invTblName, false);
+ }
+ ArrayList<FieldSchema> cols = new ArrayList<FieldSchema>(2);
+ cols.add(new FieldSchema("name", Constants.STRING_TYPE_NAME, ""));
+ cols.add(new FieldSchema("income", Constants.INT_TYPE_NAME, ""));
+
+ // create a valid table
+ tbl.setTableName(tblName);
+ tbl.getSd().setCols(cols);
+ client.createTable(tbl);
+
+ // now try to invalid alter table
+ Table tbl2 = client.getTable(dbName, tblName);
+ failed = false;
+ try {
+ tbl2.setTableName(invTblName);
+ tbl2.getSd().setCols(invCols);
+ client.alter_table(dbName, tblName, tbl2);
+ } catch (InvalidOperationException ex) {
+ failed = true;
+ }
+ if(!failed) {
+ assertTrue("Able to rename table with invalid name: " + invTblName, false);
+ }
+ // try a valid alter table
+ tbl2.setTableName(tblName);
+ tbl2.getSd().setCols(cols);
+ tbl2.getSd().setNumBuckets(32);
+ client.alter_table(dbName, tblName, tbl2);
+ Table tbl3 = client.getTable(dbName, tblName);
+ assertEquals("Alter table didn't succeed. Num buckets ", tbl2.getSd().getNumBuckets(), tbl3.getSd().getNumBuckets());
+ } catch (Exception e) {
+ System.err.println(StringUtils.stringifyException(e));
+ System.err.println("testSimpleTable() failed.");
+ throw e;
+ }
+ }
public void testComplexTable() throws Exception {
String dbName = "compdb";
Modified: hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestPartitions.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestPartitions.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestPartitions.java (original)
+++ hadoop/core/trunk/src/contrib/hive/metastore/src/test/org/apache/hadoop/hive/metastore/TestPartitions.java Mon Nov 10 17:50:06 2008
@@ -60,8 +60,8 @@
fileSys_.mkdirs(part2);
List<String> partitions = bar1.getPartitions();
assertTrue(partitions.size() == 2);
- assertTrue(partitions.get(0).equals("ds=2008-01-01"));
- assertTrue(partitions.get(1).equals("ds=2008-01-02"));
+ assertTrue(partitions.contains("ds=2008-01-01"));
+ assertTrue(partitions.contains("ds=2008-01-02"));
cleanup();
} catch(MetaException e) {
e.printStackTrace();
Modified: hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/Driver.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/Driver.java (original)
+++ hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/Driver.java Mon Nov 10 17:50:06 2008
@@ -218,7 +218,7 @@
public boolean getResults(Vector<String> res)
{
- if (sem.getFetchTask() != null) {
+ if (sem != null && sem.getFetchTask() != null) {
if (!sem.getFetchTaskInit()) {
sem.setFetchTaskInit(true);
sem.getFetchTask().initialize(conf);
Modified: hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java?rev=712905&r1=712904&r2=712905&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java (original)
+++ hadoop/core/trunk/src/contrib/hive/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnInfo.java Mon Nov 10 17:50:06 2008
@@ -73,4 +73,11 @@
public void setInternalName(String internalName) {
this.internalName = internalName;
}
+
+ /**
+ * Returns the string representation of the ColumnInfo.
+ */
+ public String toString() {
+ return internalName + ": " + type;
+ }
}