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 © 2016 The Apache Software Foundation. All rights reserved.