Package org.pentaho.di.trans.streaming.common

Class Summary

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.