Uses of Class
org.pentaho.di.trans.SubtransExecutor

Packages that use SubtransExecutor

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

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

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

Modifier and Type	Method	Description
SubtransExecutor	BaseStreamStep.getSubtransExecutor()

Constructors in org.pentaho.di.trans.streaming.common with parameters of type SubtransExecutor

Modifier	Constructor	Description
	FixedTimeStreamWindow(SubtransExecutor subtransExecutor, org.pentaho.di.core.row.RowMetaInterface rowMeta, long millis, int batchSize, int parallelism)
	FixedTimeStreamWindow(SubtransExecutor subtransExecutor, org.pentaho.di.core.row.RowMetaInterface rowMeta, long millis, int batchSize, int parallelism, io.reactivex.functions.Consumer<Map.Entry<List<I>,org.pentaho.di.core.Result>> postProcessor)
	FixedTimeStreamWindow(SubtransExecutor subtransExecutor, org.pentaho.di.core.row.RowMetaInterface rowMeta, long millis, int batchSize, int parallelism, io.reactivex.functions.Consumer<Map.Entry<List<I>,org.pentaho.di.core.Result>> postProcessor, io.reactivex.functions.Function<List<I>,List<I>> bufferFilter)