public static class ComputeWithCollectorFunctions.ComputeFuncImpl extends java.lang.Object implements ComputeCollectorFunc, java.io.Serializable
Modifier and Type | Method and Description |
---|---|
void |
compute(java.lang.Object input,
RecordCollector output) |
void |
prepare(TSetContext context)
Prepare the function.
|
public void prepare(TSetContext context)
TFunction
public void compute(java.lang.Object input, RecordCollector output)
compute
in interface ComputeCollectorFunc