[ https://issues.apache.org/jira/browse/HIVE-896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13622998#comment-13622998 ]
Hudson commented on HIVE-896: ----------------------------- Integrated in Hive-trunk-hadoop2 #138 (See [https://builds.apache.org/job/Hive-trunk-hadoop2/138/]) HIVE-896 : Add LEAD/LAG/FIRST/LAST analytical windowing functions to Hive. (Harish Butani via Ashutosh Chauhan) (Revision 1463556) Result = FAILURE hashutosh : http://svn.apache.org/viewcvs.cgi/?root=Apache-SVN&view=rev&rev=1463556 Files : * /hive/trunk/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java * /hive/trunk/data/files/flights_tiny.txt * /hive/trunk/data/files/over10k * /hive/trunk/data/files/part.rc * /hive/trunk/data/files/part.seq * /hive/trunk/data/files/part_tiny.txt * /hive/trunk/ql/if/queryplan.thrift * /hive/trunk/ql/src/gen/thrift/gen-cpp/queryplan_types.cpp * /hive/trunk/ql/src/gen/thrift/gen-cpp/queryplan_types.h * /hive/trunk/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Operator.java * /hive/trunk/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/OperatorType.java * /hive/trunk/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Query.java * /hive/trunk/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Stage.java * /hive/trunk/ql/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/ql/plan/api/Task.java * /hive/trunk/ql/src/gen/thrift/gen-php/Types.php * /hive/trunk/ql/src/gen/thrift/gen-py/queryplan/ttypes.py * /hive/trunk/ql/src/gen/thrift/gen-rb/queryplan_types.rb * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/QueryProperties.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FunctionRegistry.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/OperatorFactory.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFFunctionInfo.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFOperator.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFPartition.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFPersistence.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PTFUtils.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/PartitionTableFunctionDescription.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/WindowFunctionDescription.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/WindowFunctionInfo.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/hooks/LineageInfo.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPruner.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcFactory.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/optimizer/lineage/Generator.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/ASTNode.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/FromClauseParser.g * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/HiveLexer.g * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/HiveParser.g * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/IdentifiersParser.g * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFInvocationSpec.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/PTFTranslator.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/ParseDriver.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/QB.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/QBParseInfo.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SelectClauseParser.g * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/TypeCheckProcFactory.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/WindowingComponentizer.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/WindowingExprNodeEvaluatorFactory.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/WindowingSpec.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PTFDesc.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/plan/PTFDeserializer.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/ppd/OpProcFactory.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/ppd/PredicatePushDown.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFCumeDist.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFDenseRank.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFFirstValue.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLag.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLastValue.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLead.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFLeadLag.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFNTile.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFPercentRank.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRank.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDAFRowNumber.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDFLeadLag.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/NPath.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/Noop.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/NoopWithMap.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/TableFunctionEvaluator.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/TableFunctionResolver.java * /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/WindowingTableFunction.java * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_AggrFuncsWithNoGBYNoPartDef.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_AmbiguousWindowDefn.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_DistributeByOrderBy.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_DuplicateWindowAlias.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_HavingLeadWithNoGBYNoWindowing.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_HavingLeadWithPTF.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_InvalidValueBoundary.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_JoinWithAmbigousAlias.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_PartitionBySortBy.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_negative_WhereWithRankCond.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_window_boundaries.q * /hive/trunk/ql/src/test/queries/clientnegative/ptf_window_boundaries2.q * /hive/trunk/ql/src/test/queries/clientpositive/leadlag.q * /hive/trunk/ql/src/test/queries/clientpositive/leadlag_queries.q * /hive/trunk/ql/src/test/queries/clientpositive/ptf.q * /hive/trunk/ql/src/test/queries/clientpositive/ptf_general_queries.q * /hive/trunk/ql/src/test/queries/clientpositive/ptf_npath.q * /hive/trunk/ql/src/test/queries/clientpositive/ptf_rcfile.q * /hive/trunk/ql/src/test/queries/clientpositive/ptf_seqfile.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_columnPruning.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_expressions.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_multipartitioning.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_navfn.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_ntile.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_rank.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_udaf.q * /hive/trunk/ql/src/test/queries/clientpositive/windowing_windowspec.q * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_AggrFuncsWithNoGBYNoPartDef.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_AmbiguousWindowDefn.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_DistributeByOrderBy.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_DuplicateWindowAlias.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_HavingLeadWithNoGBYNoWindowing.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_HavingLeadWithPTF.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_InvalidValueBoundary.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_JoinWithAmbigousAlias.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_PartitionBySortBy.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_negative_WhereWithRankCond.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_window_boundaries.q.out * /hive/trunk/ql/src/test/results/clientnegative/ptf_window_boundaries2.q.out * /hive/trunk/ql/src/test/results/clientpositive/leadlag.q.out * /hive/trunk/ql/src/test/results/clientpositive/leadlag_queries.q.out * /hive/trunk/ql/src/test/results/clientpositive/ptf.q.out * /hive/trunk/ql/src/test/results/clientpositive/ptf_general_queries.q.out * /hive/trunk/ql/src/test/results/clientpositive/ptf_npath.q.out * /hive/trunk/ql/src/test/results/clientpositive/ptf_rcfile.q.out * /hive/trunk/ql/src/test/results/clientpositive/ptf_seqfile.q.out * /hive/trunk/ql/src/test/results/clientpositive/show_functions.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_columnPruning.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_expressions.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_multipartitioning.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_navfn.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_ntile.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_rank.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_udaf.q.out * /hive/trunk/ql/src/test/results/clientpositive/windowing_windowspec.q.out > Add LEAD/LAG/FIRST/LAST analytical windowing functions to Hive. > --------------------------------------------------------------- > > Key: HIVE-896 > URL: https://issues.apache.org/jira/browse/HIVE-896 > Project: Hive > Issue Type: New Feature > Components: OLAP, UDF > Reporter: Amr Awadallah > Assignee: Harish Butani > Priority: Minor > Fix For: 0.11.0 > > Attachments: DataStructs.pdf, HIVE-896.1.patch.txt, > Hive-896.2.patch.txt, hive-896.3.patch.txt, HIVE-896.4.patch, > HIVE-896.5.patch.txt > > > Windowing functions are very useful for click stream processing and similar > time-series/sliding-window analytics. > More details at: > http://download-west.oracle.com/docs/cd/B13789_01/server.101/b10736/analysis.htm#i1006709 > http://download-west.oracle.com/docs/cd/B13789_01/server.101/b10736/analysis.htm#i1007059 > http://download-west.oracle.com/docs/cd/B13789_01/server.101/b10736/analysis.htm#i1007032 > -- amr -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira