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