org.apache.reef.wake.examples.accumulate

Class CombinerStage<K extends Comparable<K>,V>

java.lang.Object

org.apache.reef.wake.examples.accumulate.CombinerStage<K,V>

Type Parameters:

K - key

V - value

All Implemented Interfaces:

AutoCloseable, Stage

public class CombinerStage<K extends Comparable<K>,V>
extends Object
implements Stage

key-value pair Combiner stage.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CombinerStage.Combiner<K extends Comparable<K>,V> key-value pair Combiner Interface.
static class	CombinerStage.Pair<K extends Comparable<K>,V> A comparable key-value pair.

Constructor Summary

Constructors

Constructor and Description
CombinerStage(CombinerStage.Combiner<K,V> c, Observer<Map.Entry<K,V>> o)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Observer<Map.Entry<K,V>>	wireIn()

Methods inherited from class java.lang.Object

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

Constructor Detail

CombinerStage

public CombinerStage(CombinerStage.Combiner<K,V> c,
             Observer<Map.Entry<K,V>> o)

Method Detail

wireIn

public Observer<Map.Entry<K,V>> wireIn()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception