Module swim.streamlet

Package swim.streamlet.combinator

Class ReduceFieldsOperator<K,V,I,O>

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

Modifier and Type	Field	Description
protected BTreeMap<K,V,O>	state

Fields inherited from class swim.streamlet.AbstractMapInletOutlet

effects, input, outputs, version

Constructor Summary

Constructors

Constructor	Description
ReduceFieldsOperator()

Method Summary

Modifier and Type	Method	Description
abstract O	accumulate(O result, V value)
abstract O	combine(O result, O value)
O	get()	Returns the current state of this Outlet.
abstract O	identity()
protected void	onRecohereOutputKey(K key, KeyEffect effect, int version)

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface swim.streamlet.Outlet

map, memoize, watch

Field Details

state

protected BTreeMap<K,V,O> state

Constructor Details

ReduceFieldsOperator

public ReduceFieldsOperator()

Method Details

get

public O get()

Description copied from interface: Outlet

Returns the current state of this Outlet.

Specified by:

get in interface Outlet<K>

Specified by:

get in class AbstractMapInletOutlet<K,V,I,O>

onRecohereOutputKey

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

Overrides:

onRecohereOutputKey in class AbstractMapInletOutlet<K,V,I,O>

identity

public abstract O identity()

accumulate

public abstract O accumulate(O result,
 V value)

combine

public abstract O combine(O result,
 O value)