MapInlet (Swim System)

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.