Uses of Interface
org.pentaho.di.trans.streaming.api.StreamSource

Packages that use StreamSource

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

Uses of StreamSource in org.pentaho.di.trans.streaming.common

Classes in org.pentaho.di.trans.streaming.common that implement StreamSource

Modifier and Type	Class and Description
class	BlockingQueueStreamSource<T> Implementation of StreamSource which handles pause/resume logic, as well as creation of .rows() which generates a blocking iterable.

Fields in org.pentaho.di.trans.streaming.common declared as StreamSource

Modifier and Type	Field and Description
protected StreamSource<List<Object>>	BaseStreamStep.source

Methods in org.pentaho.di.trans.streaming.common that return StreamSource

Modifier and Type	Method and Description
StreamSource<List<Object>>	BaseStreamStep.getSource()

Methods in org.pentaho.di.trans.streaming.common with parameters of type StreamSource

Modifier and Type	Method and Description
void	BaseStreamStep.setSource(StreamSource<List<Object>> source)