java.lang.Object
swim.streamlet.AbstractMapInletOutlet<K,V,I,O>
swim.streamlet.combinator.ReduceFieldsOperator<K,V,I,O>
- All Implemented Interfaces:
Inlet<I>
,MapInlet<K,
,V, I> MapInletOutlet<K,
,V, I, O> Outlet<O>
- Direct Known Subclasses:
ReduceFieldsCombinator
-
Field Summary
Fields inherited from class swim.streamlet.AbstractMapInletOutlet
effects, input, outputs, version
-
Constructor Summary
-
Method Summary
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
-
state
-
-
Constructor Details
-
ReduceFieldsOperator
public ReduceFieldsOperator()
-
-
Method Details
-
get
Description copied from interface:Outlet
Returns the current state of thisOutlet
. -
onRecohereOutputKey
- Overrides:
onRecohereOutputKey
in classAbstractMapInletOutlet<K,
V, I, O>
-
identity
-
accumulate
-
combine
-