|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.trans.step.BaseStep org.pentaho.di.trans.steps.singlethreader.SingleThreader
public class SingleThreader
Execute a mapping: a re-usuable transformation
Field Summary |
---|
Fields inherited from class org.pentaho.di.trans.step.BaseStep |
---|
first, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, terminator, terminator_rows |
Constructor Summary | |
---|---|
SingleThreader(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
Trans |
getMappingTrans()
|
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
Initialize and do work where other steps need to wait for... |
void |
prepareMappingExecution()
|
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process rows in batches of N rows. |
void |
stopAll()
Flags all rowsets as stopped/completed/finished. |
void |
stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Perform actions to stop a running step. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.core.variables.VariableSpace |
---|
copyVariablesFrom, environmentSubstitute, environmentSubstitute, getBooleanValueOfVariable, getParentVariableSpace, getVariable, getVariable, initializeVariablesFrom, injectVariables, listVariables, setParentVariableSpace, setVariable, shareVariablesWith |
Constructor Detail |
---|
public SingleThreader(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
Method Detail |
---|
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
processRow
in interface StepInterface
processRow
in class BaseStep
smi
- The steps metadata to work withsdi
- The steps temporary working data to work with (database connections, result sets, caches, temporary variables, etc.)
KettleException
public void prepareMappingExecution() throws KettleException
KettleException
public boolean init(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
init
in interface StepInterface
init
in class BaseStep
smi
- The metadata to work withsdi
- The data to initializepublic void dispose(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
dispose
in interface StepInterface
dispose
in class BaseStep
smi
- The metadata to work withsdi
- The data to dispose ofpublic void stopRunning(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface) throws KettleException
BaseStep
stopRunning
in interface StepInterface
stopRunning
in class BaseStep
stepMetaInterface
- The metadata that might be needed by the step to stop running.stepDataInterface
- The interface to the step data containing the connections, resultsets, open files, etc.
KettleException
- in case something goes wrongpublic void stopAll()
StepInterface
stopAll
in interface StepInterface
stopAll
in class BaseStep
public Trans getMappingTrans()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |