|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.pentaho.di.trans.steps.scriptvalues_mod.ScriptValuesModDummy
public class ScriptValuesModDummy
Dummy class used for test().
Constructor Summary | |
---|---|
ScriptValuesModDummy(org.pentaho.di.core.row.RowMetaInterface inputRowMeta,
org.pentaho.di.core.row.RowMetaInterface outputRowMeta)
|
Method Summary | |
---|---|
void |
addRowListener(RowListener rowListener)
Add a rowlistener to the step allowing you to inspect (or manipulate, be careful) the rows coming in or exiting the step. |
void |
addStepListener(StepListener stepListener)
Attach a step listener to be notified when a step arrives in a certain state. |
void |
cleanup()
Call this method typically, after ALL the slave transformations in a clustered run have finished. |
void |
copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
|
void |
dispose(StepMetaInterface sii,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
String |
environmentSubstitute(String aString)
|
String[] |
environmentSubstitute(String[] string)
|
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue)
|
int |
getCopy()
|
long |
getErrors()
Get the number of errors |
org.pentaho.di.core.row.RowMetaInterface |
getInputRowMeta()
|
List<org.pentaho.di.core.RowSet> |
getInputRowSets()
|
long |
getLinesInput()
|
long |
getLinesOutput()
|
long |
getLinesRead()
|
long |
getLinesRejected()
|
long |
getLinesUpdated()
|
long |
getLinesWritten()
|
org.pentaho.di.core.row.RowMetaInterface |
getOutputRowMeta()
|
List<org.pentaho.di.core.RowSet> |
getOutputRowSets()
|
org.pentaho.di.core.variables.VariableSpace |
getParentVariableSpace()
|
String |
getPartitionID()
|
Object[] |
getRow()
|
List<RowListener> |
getRowListeners()
|
String |
getStepID()
|
StepMeta |
getStepMeta()
|
String |
getStepname()
Get the name of the step. |
String |
getVariable(String variableName)
|
String |
getVariable(String variableName,
String defaultValue)
|
boolean |
init(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Initialise and do work where other steps need to wait for... |
void |
initBeforeStart()
This method is executed by Trans right before the threads start and right after initialization. !!! A plugin implementing this method should make sure to also call super.initBeforeStart(); !!! |
void |
initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
injectVariables(Map<String,String> prop)
|
boolean |
isAlive()
Is the thread still alive? |
boolean |
isMapping()
|
boolean |
isPartitioned()
|
boolean |
isStopped()
|
String[] |
listVariables()
|
void |
markStart()
Mark the start time of the step. |
void |
markStop()
Mark the end time of the step. |
void |
pauseRunning()
Pause a running step |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process one row. |
void |
putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row)
Put a row on the destination rowsets. |
void |
removeRowListener(RowListener rowListener)
Remove a rowlistener from this step. |
void |
resumeRunning()
Resume a running step |
void |
run()
Run is where the action happens in a step... |
void |
setErrors(long errors)
Sets the number of errors |
void |
setLinesRejected(long linesRejected)
|
void |
setOutputDone()
Signal output done to destination steps |
void |
setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
setPartitionID(String partitionID)
|
void |
setVariable(String variableName,
String variableValue)
|
void |
shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
|
void |
start()
Starts the thread... |
void |
stopAll()
Flags all rowsets as stopped/completed/finished. |
void |
stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Stop running operations... |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ScriptValuesModDummy(org.pentaho.di.core.row.RowMetaInterface inputRowMeta, org.pentaho.di.core.row.RowMetaInterface outputRowMeta)
Method Detail |
---|
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
StepInterface
processRow
in interface StepInterface
processRow
in interface ScriptValuesModInterface
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 addRowListener(RowListener rowListener)
StepInterface
addRowListener
in interface StepInterface
addRowListener
in interface ScriptValuesModInterface
rowListener
- the rowlistener to addpublic void dispose(StepMetaInterface sii, StepDataInterface sdi)
StepInterface
dispose
in interface StepInterface
dispose
in interface ScriptValuesModInterface
sii
- The metadata to work withsdi
- The data to dispose ofpublic long getErrors()
StepInterface
getErrors
in interface StepInterface
getErrors
in interface ScriptValuesModInterface
public List<org.pentaho.di.core.RowSet> getInputRowSets()
getInputRowSets
in interface StepInterface
getInputRowSets
in interface ScriptValuesModInterface
public long getLinesInput()
getLinesInput
in interface StepInterface
getLinesInput
in interface ScriptValuesModInterface
public long getLinesOutput()
getLinesOutput
in interface StepInterface
getLinesOutput
in interface ScriptValuesModInterface
public long getLinesRead()
getLinesRead
in interface StepInterface
getLinesRead
in interface ScriptValuesModInterface
public long getLinesUpdated()
getLinesUpdated
in interface StepInterface
getLinesUpdated
in interface ScriptValuesModInterface
public long getLinesWritten()
getLinesWritten
in interface StepInterface
getLinesWritten
in interface ScriptValuesModInterface
public long getLinesRejected()
getLinesRejected
in interface StepInterface
getLinesRejected
in interface ScriptValuesModInterface
public List<org.pentaho.di.core.RowSet> getOutputRowSets()
getOutputRowSets
in interface StepInterface
getOutputRowSets
in interface ScriptValuesModInterface
public String getPartitionID()
getPartitionID
in interface StepInterface
getPartitionID
in interface ScriptValuesModInterface
public Object[] getRow() throws org.pentaho.di.core.exception.KettleException
getRow
in interface StepInterface
getRow
in interface ScriptValuesModInterface
org.pentaho.di.core.exception.KettleException
public List<RowListener> getRowListeners()
getRowListeners
in interface StepInterface
getRowListeners
in interface ScriptValuesModInterface
public String getStepID()
getStepID
in interface StepInterface
getStepID
in interface ScriptValuesModInterface
public String getStepname()
StepInterface
getStepname
in interface StepInterface
getStepname
in interface ScriptValuesModInterface
public boolean init(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface)
StepInterface
init
in interface StepInterface
init
in interface ScriptValuesModInterface
stepMetaInterface
- The metadata to work withstepDataInterface
- The data to initializepublic boolean isAlive()
StepInterface
isAlive
in interface StepInterface
isAlive
in interface ScriptValuesModInterface
public boolean isPartitioned()
isPartitioned
in interface StepInterface
isPartitioned
in interface ScriptValuesModInterface
public boolean isStopped()
isStopped
in interface StepInterface
isStopped
in interface ScriptValuesModInterface
public void markStart()
StepInterface
markStart
in interface StepInterface
markStart
in interface ScriptValuesModInterface
public void markStop()
StepInterface
markStop
in interface StepInterface
markStop
in interface ScriptValuesModInterface
public void putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) throws org.pentaho.di.core.exception.KettleException
StepInterface
putRow
in interface StepInterface
putRow
in interface ScriptValuesModInterface
rowMeta
- The row to send to the destinations steps
org.pentaho.di.core.exception.KettleException
public void removeRowListener(RowListener rowListener)
StepInterface
removeRowListener
in interface StepInterface
removeRowListener
in interface ScriptValuesModInterface
rowListener
- the rowlistener to removepublic void run()
StepInterface
run
in interface StepInterface
run
in interface ScriptValuesModInterface
public void setErrors(long errors)
StepInterface
setErrors
in interface StepInterface
setErrors
in interface ScriptValuesModInterface
errors
- the number of errors to setpublic void setOutputDone()
StepInterface
setOutputDone
in interface StepInterface
setOutputDone
in interface ScriptValuesModInterface
public void setPartitionID(String partitionID)
setPartitionID
in interface StepInterface
setPartitionID
in interface ScriptValuesModInterface
partitionID
- the partitionID to setpublic void start()
StepInterface
start
in interface StepInterface
start
in interface ScriptValuesModInterface
public void stopAll()
StepInterface
stopAll
in interface StepInterface
stopAll
in interface ScriptValuesModInterface
public void stopRunning(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface) throws org.pentaho.di.core.exception.KettleException
StepInterface
stopRunning
in interface StepInterface
stopRunning
in interface ScriptValuesModInterface
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
public void cleanup()
StepInterface
cleanup
in interface StepInterface
cleanup
in interface ScriptValuesModInterface
public void pauseRunning()
StepInterface
pauseRunning
in interface StepInterface
pauseRunning
in interface ScriptValuesModInterface
public void resumeRunning()
StepInterface
resumeRunning
in interface StepInterface
resumeRunning
in interface ScriptValuesModInterface
public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
copyVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String environmentSubstitute(String aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public String[] environmentSubstitute(String[] string)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
in interface org.pentaho.di.core.variables.VariableSpace
public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
getParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
setParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName, String defaultValue)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
initializeVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public void injectVariables(Map<String,String> prop)
injectVariables
in interface org.pentaho.di.core.variables.VariableSpace
public String[] listVariables()
listVariables
in interface org.pentaho.di.core.variables.VariableSpace
public void setVariable(String variableName, String variableValue)
setVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
shareVariablesWith
in interface org.pentaho.di.core.variables.VariableSpace
public org.pentaho.di.core.row.RowMetaInterface getInputRowMeta()
public org.pentaho.di.core.row.RowMetaInterface getOutputRowMeta()
public void initBeforeStart() throws org.pentaho.di.core.exception.KettleStepException
StepInterface
initBeforeStart
in interface StepInterface
org.pentaho.di.core.exception.KettleStepException
- In case there is an errorpublic void setLinesRejected(long linesRejected)
setLinesRejected
in interface StepInterface
linesRejected
- steps the lines rejected by error handling.public int getCopy()
getCopy
in interface StepInterface
public void addStepListener(StepListener stepListener)
StepInterface
addStepListener
in interface StepInterface
stepListener
- The listener to add to the steppublic boolean isMapping()
isMapping
in interface StepInterface
public StepMeta getStepMeta()
getStepMeta
in interface StepInterface
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |