| Interface | Description |
|---|---|
| OperatorActions |
Interface for
StreamOperator actions. |
| Class | Description |
|---|---|
| AsyncWaitOperator<IN,OUT> |
The
AsyncWaitOperator allows to asynchronously process incoming stream records. |
| Emitter<OUT> |
Runnable responsible for consuming elements from the given queue and outputting them to the
given output/timestampedCollector.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.