|
||||||||||
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.combinationlookup.CombinationLookup
public class CombinationLookup
Manages or looks up information in a Type 1 or junk dimension.
1) Lookup combination field1..n in a dimension
2) If this combination exists, return technical key
3) If this combination doesn't exist, insert & return technical key
4) if replace is Y, remove all key fields from output.
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 | |
---|---|
CombinationLookup(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
Long |
combiInsert(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row,
Long val_key,
Long val_crc)
This inserts new record into a junk dimension |
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
boolean |
init(StepMetaInterface sii,
StepDataInterface sdi)
Initialise and do work where other steps need to wait for... |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process one row. |
void |
run()
Run is where the action happens in a step... |
void |
setCombiLookup(org.pentaho.di.core.row.RowMetaInterface inputRowMeta)
CombinationLookup table: dimension table keys[]: which dim-fields do we use to look up key? retval: name of the key to return |
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 |
---|
addRowListener, addStepListener, cleanup, getCopy, getErrors, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesUpdated, getLinesWritten, getOutputRowSets, getPartitionID, getRow, getRowListeners, getStepID, getStepMeta, getStepname, initBeforeStart, isAlive, isMapping, isPartitioned, isStopped, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, setErrors, setLinesRejected, setOutputDone, setPartitionID, start, stopAll, stopRunning |
Constructor Detail |
---|
public CombinationLookup(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
StepInterface
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 setCombiLookup(org.pentaho.di.core.row.RowMetaInterface inputRowMeta) throws org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleDatabaseException
public Long combiInsert(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, Long val_key, Long val_crc) throws org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleDatabaseException
public boolean init(StepMetaInterface sii, StepDataInterface sdi)
StepInterface
init
in interface StepInterface
init
in class BaseStep
sii
- 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 run()
StepInterface
run
in interface Runnable
run
in interface StepInterface
run
in class Thread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |