Module swim.streamlet

Package swim.streamlet.combinator

Class WatchFieldsOperator<K,V,O>

java.lang.Object

swim.streamlet.AbstractMapInlet<K,V,O>

swim.streamlet.combinator.WatchFieldsOperator<K,V,O>

All Implemented Interfaces:

Inlet<O>, MapInlet<K,V,O>

Direct Known Subclasses:

WatchFieldsCombinator

public abstract class WatchFieldsOperator<K,V,O>
extends AbstractMapInlet<K,V,O>

Field Summary

Fields inherited from class swim.streamlet.AbstractMapInlet

effects, input, version

Constructor Summary

Constructors

Constructor	Description
WatchFieldsOperator()

Method Summary

Modifier and Type	Method	Description
abstract void	evaluate(K key, V value)
protected void	onRecohereOutputKey(K key, KeyEffect effect, int version)

Methods inherited from class swim.streamlet.AbstractMapInlet

bindInput, bindInput, decohereOutput, decohereOutputKey, didDecohereOutput, didDecohereOutputKey, didRecohereOutput, didRecohereOutputKey, disconnectInputs, disconnectOutputs, input, onDecohereOutput, onDecohereOutputKey, onRecohereOutput, recohereOutput, recohereOutputKey, unbindInput, willDecohereOutput, willDecohereOutputKey, willRecohereOutput, willRecohereOutputKey

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WatchFieldsOperator

public WatchFieldsOperator()

Method Details

onRecohereOutputKey

protected void onRecohereOutputKey(K key,
 KeyEffect effect,
 int version)

Overrides:

onRecohereOutputKey in class AbstractMapInlet<K,V,O>

evaluate

public abstract void evaluate(K key,
 V value)