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	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	Description
protected StreamSource<List<Object>>	BaseStreamStep.source

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

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

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

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