- 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
public abstract class ReduceFieldsOperator<K,V,I,O> extends AbstractMapInletOutlet<K,V,I,O>
-
-
Field Summary
-
Fields inherited from class swim.streamlet.AbstractMapInletOutlet
effects, input, outputs, version
-
-
Constructor Summary
Constructors Constructor Description ReduceFieldsOperator()
-
Method Summary
-
Methods inherited from class swim.streamlet.AbstractMapInletOutlet
bindInput, bindInput, bindOutput, didInvalidate, didInvalidateOutputKey, didReconcile, didReconcileOutputKey, disconnectInputs, disconnectOutputs, input, invalidate, invalidateInput, invalidateOutput, invalidateOutputKey, onInvalidate, onInvalidateOutputKey, onReconcile, outputIterator, reconcile, reconcileInput, reconcileOutput, reconcileOutputKey, unbindInput, unbindOutput, unbindOutputs, willInvalidate, willInvalidateOutputKey, willReconcile, willReconcileOutputKey
-
-
-
-
Method Detail
-
get
public O get()
Description copied from interface:Outlet
Returns the current state of thisOutlet
.
-
onReconcileOutputKey
protected void onReconcileOutputKey(K key, KeyEffect effect, int version)
- Overrides:
onReconcileOutputKey
in classAbstractMapInletOutlet<K,V,I,O>
-
identity
public abstract O identity()
-
-