public static interface AggregateBy.Functor extends Serializable
AggregateBy.CompositeFunction
class.
Note the FlowProcess
argument provides access to the underlying properties and counter APIs.Modifier and Type | Method and Description |
---|---|
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.
|
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 TupleCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.