Module swim.streamlet

Package swim.streamlet

Interface MapInlet<K,V,I>

All Superinterfaces:

Inlet<I>

All Known Subinterfaces:

MapDownlink<K,V>, MapInletMapOutlet<KI,KO,VI,VO,I,O>, MapInletOutlet<K,V,I,O>, MapInoutlet<K,VI,VO,I,O>, MapLane<K,V>

All Known Implementing Classes:

AbstractMapInlet, AbstractMapInletMapOutlet, AbstractMapInletOutlet, AbstractMapInoutlet, FilterFieldsCombinator, FilterFieldsOperator, JoinMapLaneDownlink, MapDownlinkView, MapFieldValuesCombinator, MapFieldValuesOperator, MapLaneView, MapOutput, MemoizeMapCombinator, OutletMapInlet, ReduceFieldsCombinator, ReduceFieldsOperator, WatchFieldsCombinator, WatchFieldsOperator

public interface MapInlet<K,V,I>
extends Inlet<I>

Input connector into a Streamlet for a key-value map state.

Method Summary

Modifier and Type	Method	Description
void	invalidateOutputKey(K key, KeyEffect effect)	Marks this MapInlet as needing an effect applied to a given key.
void	reconcileOutputKey(K key, int version)	Reconciles the state of an individual key in this MapInlet, if the version of this MapInlet's state differs from the target version.

Methods inherited from interface swim.streamlet.Inlet

bindInput, disconnectInputs, disconnectOutputs, input, invalidateOutput, reconcileOutput, unbindInput

Method Detail

invalidateOutputKey

void invalidateOutputKey(K key,
                         KeyEffect effect)

Marks this MapInlet as needing an effect applied to a given key. Invalidating an individual key invalidates the entire state of the Inlet. But only the invalidated keys need to be updated in order to reconcile the overall state of the Inlet.

reconcileOutputKey

void reconcileOutputKey(K key,
                        int version)

Reconciles the state of an individual key in this MapInlet, if the version of this MapInlet's state differs from the target version. To reconcile the state of a key, the MapInlet first invokes MapOutlet.reconcileInputKey(Object, int) on its input, if its input is a MapOutlet, or it invokes Outlet.reconcileInput(int), if its input is not a MapOutlet. Then, if all invalid keys have been reconciled, the MapInlet invokes Streamlet.reconcile(int) on its attached streamlet.