org.apache.hadoop.hive.ql.udf.generic

Interface ISupportStreamingModeForWindowing

All Known Implementing Classes:

GenericUDAFDenseRank.GenericUDAFDenseRankEvaluator, GenericUDAFRank.GenericUDAFRankEvaluator, GenericUDAFStreamingEvaluator, GenericUDAFStreamingEvaluator.SumAvgEnhancer

public interface ISupportStreamingModeForWindowing

A GenericUDAF mode that provides it results as a List to the WindowingTableFunction (so it is a WindowFunctionInfo.isPivotResult() return true) may support this interface. If it does then the WindowingTableFunction will ask it for the next Result after every aggregate call.

Field Summary

Fields

Modifier and Type	Field and Description
static Object	NULL_RESULT

Method Summary

Methods

Modifier and Type	Method and Description
Object	getNextResult(GenericUDAFEvaluator.AggregationBuffer agg)
int	getRowsRemainingAfterTerminate()

Field Detail

NULL_RESULT

static final Object NULL_RESULT

Method Detail

getNextResult

Object getNextResult(GenericUDAFEvaluator.AggregationBuffer agg)
                     throws HiveException

Throws:

HiveException

getRowsRemainingAfterTerminate

int getRowsRemainingAfterTerminate()
                                   throws HiveException

Throws:

HiveException