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