|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.pipe.assembly.MinBy.MinPartials
public static class MinBy.MinPartials
Constructor Summary | |
---|---|
MinBy.MinPartials(Fields declaredFields)
Constructor MinPartials creates a new MinPartials instance. |
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MinBy.MinPartials(Fields declaredFields)
Method Detail |
---|
public Fields getDeclaredFields()
AggregateBy.Functor
getDeclaredFields
in interface AggregateBy.Functor
public Tuple aggregate(FlowProcess flowProcess, TupleEntry args, Tuple context)
AggregateBy.Functor
null
. All subsequent
invocations context will be the value returned on the previous invocation.
aggregate
in interface AggregateBy.Functor
flowProcess
- of type FlowProcessargs
- of type TupleEntrycontext
- of type Tuple @return Tuplepublic Tuple complete(FlowProcess flowProcess, Tuple context)
AggregateBy.Functor
Tuple
instance must match the number of declaredFields.
It is safe to return the context object as the result value.
complete
in interface AggregateBy.Functor
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 |