java.lang.Object
swim.streamlet.AbstractMapInletOutlet<K,V,I,O>
swim.streamlet.combinator.ReduceFieldsOperator<K,V,I,O>
swim.streamlet.combinator.ReduceFieldsCombinator<K,V,I,O>
- All Implemented Interfaces:
Inlet<I>
,MapInlet<K,
,V, I> MapInletOutlet<K,
,V, I, O> Outlet<O>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final CombinerFunction<? super V,
O> protected final CombinerFunction<O,
O> protected final O
Fields inherited from class swim.streamlet.combinator.ReduceFieldsOperator
state
Fields inherited from class swim.streamlet.AbstractMapInletOutlet
effects, input, outputs, version
-
Constructor Summary
ConstructorsConstructorDescriptionReduceFieldsCombinator
(O identity, CombinerFunction<? super V, O> accumulator, CombinerFunction<O, O> combiner) -
Method Summary
Methods inherited from class swim.streamlet.combinator.ReduceFieldsOperator
onRecohereOutputKey
Methods inherited from class swim.streamlet.AbstractMapInletOutlet
bindInput, bindInput, bindOutput, decohere, decohereInput, decohereOutput, decohereOutputKey, didDecohere, didDecohereOutputKey, didRecohere, didRecohereOutputKey, disconnectInputs, disconnectOutputs, input, onDecohere, onDecohereOutputKey, onRecohere, outputIterator, recohere, recohereInput, recohereOutput, recohereOutputKey, unbindInput, unbindOutput, unbindOutputs, willDecohere, willDecohereOutputKey, willRecohere, willRecohereOutputKey
-
Field Details
-
identity
-
accumulator
-
combiner
-
-
Constructor Details
-
ReduceFieldsCombinator
public ReduceFieldsCombinator(O identity, CombinerFunction<? super V, O> accumulator, CombinerFunction<O, O> combiner)
-
-
Method Details
-
get
Description copied from interface:Outlet
Returns the current state of thisOutlet
. -
identity
-
accumulate
- Specified by:
accumulate
in classReduceFieldsOperator<K,
V, I, O>
-
combine
-