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)
TFunctionpublic void compute(java.lang.Object input,
RecordCollector output)
compute in interface ComputeCollectorFunc