public static class UDAFExampleAvg.UDAFExampleAvgEvaluator extends Object implements UDAFEvaluator
Constructor and Description |
---|
UDAFExampleAvgEvaluator() |
Modifier and Type | Method and Description |
---|---|
void |
init()
Reset the state of the aggregation.
|
boolean |
iterate(Double o)
Iterate through one row of original data.
|
boolean |
merge(UDAFExampleAvg.UDAFAvgState o)
Merge with a partial aggregation.
|
Double |
terminate()
Terminates the aggregation and return the final result.
|
UDAFExampleAvg.UDAFAvgState |
terminatePartial()
Terminate a partial aggregation and return the state.
|
public void init()
init
in interface UDAFEvaluator
public boolean iterate(Double o)
public UDAFExampleAvg.UDAFAvgState terminatePartial()
public boolean merge(UDAFExampleAvg.UDAFAvgState o)
public Double terminate()
Copyright © 2016 The Apache Software Foundation. All rights reserved.