| Package | Description | 
|---|---|
| org.apache.reef.wake.examples.join | 
| Modifier and Type | Method and Description | 
|---|---|
Observer<TupleEvent> | 
NonBlockingJoin.wireLeft()  | 
Observer<TupleEvent> | 
BlockingJoin.wireLeft()  | 
Observer<TupleEvent> | 
NonBlockingJoin.wireRight()  | 
Observer<TupleEvent> | 
BlockingJoin.wireRight()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
TupleEvent.compareTo(TupleEvent o)  | 
| Constructor and Description | 
|---|
BlockingJoin(Observer<TupleEvent> out)  | 
NonBlockingJoin(Observer<TupleEvent> out)  | 
TupleSource(Observer<TupleEvent> out,
                      int max,
                      int numThreads,
                      boolean evenOnly)  | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.