public class SubtransExecutor extends Object
Constructor and Description |
---|
SubtransExecutor(String subTransName,
Trans parentTrans,
TransMeta subtransMeta,
boolean shareVariables,
TransExecutorParameters parameters,
String subStep,
int prefetchCount) |
Modifier and Type | Method and Description |
---|---|
void |
acquireBufferPermit() |
Optional<Result> |
execute(List<RowMetaAndData> rows) |
Trans |
getParentTrans() |
int |
getPrefetchCount() |
Map<String,StepStatus> |
getStatuses() |
void |
stop() |
public SubtransExecutor(String subTransName, Trans parentTrans, TransMeta subtransMeta, boolean shareVariables, TransExecutorParameters parameters, String subStep, int prefetchCount)
public Optional<Result> execute(List<RowMetaAndData> rows) throws KettleException
KettleException
public void stop()
public Map<String,StepStatus> getStatuses()
public Trans getParentTrans()
public void acquireBufferPermit() throws InterruptedException
InterruptedException
public int getPrefetchCount()
Copyright © 2020 Hitachi Vantara. All rights reserved.