|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.pentaho.di.trans.step.BaseStep
org.pentaho.di.trans.steps.mapping.Mapping
public class Mapping
Execute a mapping: a re-usuable transformation
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary |
---|
Fields inherited from class org.pentaho.di.trans.step.BaseStep |
---|
category_order, errorRowSet, first, init, inputRowSets, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, outputRowSets, paused, remoteInputSteps, remoteOutputSteps, statusDesc, steps, stopped, terminator, terminator_rows, thr, waiting |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
Mapping(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
static void |
addInputRenames(List<MappingValueRename> renameList,
List<MappingValueRename> addRenameList)
|
void |
addRowListener(RowListener rowListener)
For preview of the main data path, make sure we pass the row listener down to the Mapping Output step... |
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
long |
getLinesInput()
|
long |
getLinesOutput()
|
long |
getLinesRead()
|
long |
getLinesRejected()
|
long |
getLinesUpdated()
|
long |
getLinesWritten()
|
Trans |
getMappingTrans()
|
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
Initialise and do work where other steps need to wait for... |
void |
prepareMappingExecution()
|
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process a single row. |
int |
rowsetInputSize()
|
int |
rowsetOutputSize()
|
void |
run()
Run is where the action happens in a step... |
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.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.trans.step.StepInterface |
---|
addStepListener, cleanup, getCopy, getErrors, getInputRowSets, getOutputRowSets, getPartitionID, getRow, getRowListeners, getStepID, getStepMeta, getStepname, initBeforeStart, isAlive, isMapping, isPartitioned, isStopped, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, setErrors, setLinesRejected, setOutputDone, setPartitionID, start |
Constructor Detail |
---|
public Mapping(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
Method Detail |
---|
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
processRow
in interface StepInterface
processRow
in class BaseStep
smi
- The metadata to work withsdi
- The temporary working data to work with (database connections, resultsets, caches, temporary variables, etc.)
org.pentaho.di.core.exception.KettleException
public void prepareMappingExecution() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public static void addInputRenames(List<MappingValueRename> renameList, List<MappingValueRename> addRenameList)
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 org.pentaho.di.core.exception.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.
org.pentaho.di.core.exception.KettleException
- in case something goes wrongpublic void stopAll()
StepInterface
stopAll
in interface StepInterface
stopAll
in class BaseStep
public void run()
StepInterface
run
in interface Runnable
run
in interface StepInterface
run
in class Thread
public long getLinesInput()
getLinesInput
in interface StepInterface
getLinesInput
in class BaseStep
public long getLinesOutput()
getLinesOutput
in interface StepInterface
getLinesOutput
in class BaseStep
public long getLinesRead()
getLinesRead
in interface StepInterface
getLinesRead
in class BaseStep
public long getLinesRejected()
getLinesRejected
in interface StepInterface
getLinesRejected
in class BaseStep
public long getLinesUpdated()
getLinesUpdated
in interface StepInterface
getLinesUpdated
in class BaseStep
public long getLinesWritten()
getLinesWritten
in interface StepInterface
getLinesWritten
in class BaseStep
public int rowsetInputSize()
rowsetInputSize
in class BaseStep
public int rowsetOutputSize()
rowsetOutputSize
in class BaseStep
public Trans getMappingTrans()
public void addRowListener(RowListener rowListener)
addRowListener
in interface StepInterface
addRowListener
in class BaseStep
rowListener
- the rowlistener to add
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |