|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public static interface AggregateBy.Functor
Interface Functor provides a means to create a simple function for use with the AggregateBy.CompositeFunction
class.
FlowProcess
argument provides access to the underlying properties and counter APIs.
Method Summary | |
---|---|
Tuple |
aggregate(FlowProcess flowProcess,
TupleEntry args,
Tuple context)
Method aggregate operates on the given args in tandem (optionally) with the given context values. |
Tuple |
complete(FlowProcess flowProcess,
Tuple context)
Method complete allows the final aggregate computation to be performed before the return value is collected. |
Fields |
getDeclaredFields()
Method getDeclaredFields returns the declaredFields of this Functor object. |
Method Detail |
---|
Fields getDeclaredFields()
Tuple aggregate(FlowProcess flowProcess, TupleEntry args, Tuple context)
null
. All subsequent
invocations context will be the value returned on the previous invocation.
flowProcess
- of type FlowProcessargs
- of type TupleEntrycontext
- of type Tuple @return TupleTuple complete(FlowProcess flowProcess, Tuple context)
Tuple
instance must match the number of declaredFields.
It is safe to return the context object as the result value.
flowProcess
- of type FlowProcesscontext
- of type Tuple @return Tuple
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |