ReduceFieldsOperator (SwimOS)

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

All Methods Instance Methods Abstract Methods Concrete Methods
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 Detail
- state
```
protected BTreeMap<K,V,O> state
```

Constructor Detail
- ReduceFieldsOperator
```
public ReduceFieldsOperator()
```

Method Detail

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)