| Package | Description |
|---|---|
| org.apache.reef.wake.examples.join |
Blocking and non-blocking join example.
|
| 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 © 2017 The Apache Software Foundation. All rights reserved.