Package org.pentaho.di.trans

Class SubtransExecutor

java.lang.Object

org.pentaho.di.trans.SubtransExecutor

public class SubtransExecutor
extends Object

Will run the given sub-transformation with the rows passed to execute

Constructor Summary

Constructors

Constructor	Description
SubtransExecutor(String subTransName, Trans parentTrans, TransMeta subtransMeta, boolean shareVariables, TransExecutorParameters parameters, String subStep, int prefetchCount)

Method Summary

Modifier and Type	Method	Description
void	acquireBufferPermit()
Optional<org.pentaho.di.core.Result>	execute(List<org.pentaho.di.core.RowMetaAndData> rows)
Trans	getParentTrans()
int	getPrefetchCount()
Map<String,StepStatus>	getStatuses()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubtransExecutor

public SubtransExecutor(String subTransName,
                        Trans parentTrans,
                        TransMeta subtransMeta,
                        boolean shareVariables,
                        TransExecutorParameters parameters,
                        String subStep,
                        int prefetchCount)

Method Detail

execute

public Optional<org.pentaho.di.core.Result> execute(List<org.pentaho.di.core.RowMetaAndData> rows)
                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

stop

public void stop()

getStatuses

public Map<String,StepStatus> getStatuses()

getParentTrans

public Trans getParentTrans()

acquireBufferPermit

public void acquireBufferPermit()
                         throws InterruptedException

Throws:

InterruptedException

getPrefetchCount

public int getPrefetchCount()