| Class | Description |
|---|---|
| BaseStreamStep | |
| BaseStreamStepMeta | |
| BlockingQueueStreamSource<T> |
Implementation of StreamSource which handles pause/resume logic, as well as creation of .rows() which generates a
blocking iterable.
|
| FixedTimeStreamWindow<I extends List> |
A StreamWindow implementation which buffers rows of I by a fixed amount of time and size, executing each batch in a
subtransformation.
|
Copyright © 2018 Hitachi Vantara. All rights reserved.