|
||||||||||
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
public class BaseStep
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
static String[] |
category_order
Deprecated. Please use StepCategory.STANDARD_CATEGORIES to get the natural order |
org.pentaho.di.core.RowSet |
errorRowSet
the rowset for the error rows |
boolean |
first
|
boolean |
init
|
ArrayList<org.pentaho.di.core.RowSet> |
inputRowSets
The rowsets on the input, size() == nr of source steps |
long |
linesInput
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesOutput
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesRead
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesRejected
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesSkipped
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesUpdated
Deprecated. please use the supplied getters, setters and increment/decrement methods |
long |
linesWritten
Deprecated. please use the supplied getters, setters and increment/decrement methods |
ArrayList<org.pentaho.di.core.RowSet> |
outputRowSets
the rowsets on the output, size() == nr of target steps |
AtomicBoolean |
paused
|
List<RemoteStep> |
remoteInputSteps
The remote input steps. |
List<RemoteStep> |
remoteOutputSteps
The remote output steps. |
static String[] |
statusDesc
|
static StepPluginMeta[] |
steps
|
AtomicBoolean |
stopped
|
boolean |
terminator
|
List<Object[]> |
terminator_rows
|
List<BaseStep> |
thr
|
boolean |
waiting
|
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
BaseStep(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
This is the base step that forms that basis for all steps. |
Method Summary | |
---|---|
void |
addResultFile(org.pentaho.di.core.ResultFile resultFile)
|
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. |
org.pentaho.di.core.RowMetaAndData |
buildLog(String sname,
int copynr,
long lines_read,
long lines_written,
long lines_updated,
long lines_skipped,
long errors,
Date start_date,
Date end_date)
|
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)
|
long |
decrementLinesRead()
Decrements the number of lines read from previous steps by one |
long |
decrementLinesWritten()
Decrements the number of lines written to next steps by one |
void |
dispatch()
This method finds the surrounding steps and rowsets for this base step. |
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
String |
environmentSubstitute(String aString)
|
String[] |
environmentSubstitute(String[] aString)
|
org.pentaho.di.core.RowSet |
findInputRowSet(String sourceStep)
|
org.pentaho.di.core.RowSet |
findInputRowSet(String from,
int fromcopy,
String to,
int tocopy)
|
org.pentaho.di.core.RowSet |
findOutputRowSet(String targetStep)
|
org.pentaho.di.core.RowSet |
findOutputRowSet(String from,
int fromcopy,
String to,
int tocopy)
Find an output rowset in a running transformation. |
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue)
|
int |
getClusterSize()
|
int |
getCopy()
|
Trans |
getDispatcher()
|
org.pentaho.di.core.row.RowMetaInterface |
getErrorRowMeta()
|
long |
getErrors()
Get the number of errors |
static String |
getIconFilename(int steptype)
|
org.pentaho.di.core.row.RowMetaInterface |
getInputRowMeta()
|
List<org.pentaho.di.core.RowSet> |
getInputRowSets()
|
long |
getLinesInput()
|
long |
getLinesOutput()
|
long |
getLinesRead()
|
long |
getLinesRejected()
|
long |
getLinesSkipped()
|
long |
getLinesUpdated()
|
long |
getLinesWritten()
|
static org.pentaho.di.core.row.RowMetaInterface |
getLogFields(String comm)
|
int |
getNextClassNr()
|
List<org.pentaho.di.core.RowSet> |
getOutputRowSets()
|
org.pentaho.di.core.variables.VariableSpace |
getParentVariableSpace()
|
String |
getPartitionID()
|
Map<String,org.pentaho.di.core.RowSet> |
getPartitionTargets()
|
org.pentaho.di.core.row.RowMetaInterface |
getPreviewRowMeta()
|
long |
getProcessed()
|
int |
getRepartitioning()
|
Map<String,org.pentaho.di.core.ResultFile> |
getResultFiles()
|
Object[] |
getRow()
In case of getRow, we receive data from previous steps through the input rowset. |
Object[] |
getRowFrom(org.pentaho.di.core.RowSet rowSet)
|
List<RowListener> |
getRowListeners()
|
long |
getRuntime()
|
List<ServerSocket> |
getServerSockets()
|
int |
getSlaveNr()
|
SocketRepository |
getSocketRepository()
|
int |
getStatus()
|
String |
getStatusDescription()
|
StepDataInterface |
getStepDataInterface()
|
String |
getStepID()
|
static StepMetaInterface |
getStepInfo(StepPlugin stepplugin,
StepLoader steploader)
Create a new empty StepMeta class from the steploader |
List<StepListener> |
getStepListeners()
|
StepMeta |
getStepMeta()
|
StepMetaInterface |
getStepMetaInterface()
|
String |
getStepname()
Get the name of the step. |
Thread |
getThread()
|
Trans |
getTrans()
|
TransMeta |
getTransMeta()
|
String |
getTypeId()
Support for CheckResultSourceInterface |
int |
getUniqueStepCountAcrossSlaves()
|
int |
getUniqueStepNrAcrossSlaves()
|
String |
getVariable(String variableName)
|
String |
getVariable(String variableName,
String defaultValue)
|
long |
incrementLinesInput()
Increments the number of lines read from an input source: database, file, socket, etc. |
long |
incrementLinesOutput()
Increments the number of lines written to an output target: database, file, socket, etc. |
long |
incrementLinesRead()
Increments the number of lines read from previous steps by one |
long |
incrementLinesRejected()
Increments the number of lines rejected to an error handling step |
long |
incrementLinesSkipped()
Increments the number of lines skipped |
long |
incrementLinesUpdated()
Increments the number of lines updated in an output target: database, file, socket, etc. |
long |
incrementLinesWritten()
Increments the number of lines written to next steps by one |
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
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. |
void |
initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
injectVariables(Map<String,String> prop)
|
boolean |
isDistributed()
|
boolean |
isInitialising()
|
boolean |
isMapping()
|
boolean |
isPartitioned()
|
boolean |
isPaused()
|
boolean |
isSafeModeEnabled()
|
boolean |
isStopped()
|
boolean |
isUsingThreadPriorityManagment()
|
String[] |
listVariables()
|
void |
logBasic(String s)
|
void |
logDebug(String s)
|
void |
logDetailed(String s)
|
void |
logError(String s)
|
void |
logError(String s,
Throwable e)
|
void |
logMinimal(String s)
|
void |
logRowlevel(String s)
|
void |
logSummary()
|
void |
markStart()
Mark the start time of the step. |
void |
markStop()
Mark the end time of the step. |
boolean |
outputIsDone()
|
void |
pauseRunning()
Pause a running step |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process one row. |
void |
putError(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row,
long nrErrors,
String errorDescriptions,
String fieldNames,
String errorCodes)
|
void |
putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row)
putRow is used to copy a row, to the alternate rowset(s) This should get priority over everything else! (synchronized) If distribute is true, a row is copied only once to the output rowsets, otherwise copies are sent to each rowset! |
void |
putRowTo(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row,
org.pentaho.di.core.RowSet rowSet)
putRowTo is used to put a row in a certain specific RowSet. |
void |
removeRowListener(RowListener rowListener)
Remove a rowlistener from this step. |
void |
resumeRunning()
Resume a running step |
int |
rowsetInputSize()
|
int |
rowsetOutputSize()
|
static void |
runStepThread(StepInterface stepInterface,
StepMetaInterface meta,
StepDataInterface data)
|
static void |
safeModeChecking(org.pentaho.di.core.row.RowMetaInterface referenceRowMeta,
org.pentaho.di.core.row.RowMetaInterface rowMeta)
|
void |
setCopy(int cop)
|
void |
setDistributed(boolean distributed)
|
void |
setErrorRowMeta(org.pentaho.di.core.row.RowMetaInterface errorRowMeta)
|
void |
setErrors(long e)
Sets the number of errors |
void |
setInputRowMeta(org.pentaho.di.core.row.RowMetaInterface rowMeta)
|
void |
setInputRowSets(ArrayList<org.pentaho.di.core.RowSet> inputRowSets)
|
void |
setInternalVariables()
|
void |
setLinesInput(long newLinesInputValue)
|
void |
setLinesOutput(long newLinesOutputValue)
|
void |
setLinesRead(long newLinesReadValue)
|
void |
setLinesRejected(long newLinesRejectedValue)
|
void |
setLinesSkipped(long newLinesSkippedValue)
|
void |
setLinesUpdated(long newLinesUpdatedValue)
|
void |
setLinesWritten(long newLinesWrittenValue)
|
void |
setOutputDone()
Signal output done to destination steps |
void |
setOutputRowSets(ArrayList<org.pentaho.di.core.RowSet> outputRowSets)
|
void |
setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
setPartitioned(boolean partitioned)
|
void |
setPartitionID(String partitionID)
|
void |
setPartitionTargets(Map<String,org.pentaho.di.core.RowSet> partitionTargets)
|
void |
setPaused(AtomicBoolean paused)
|
void |
setPaused(boolean paused)
|
void |
setPreviewRowMeta(org.pentaho.di.core.row.RowMetaInterface previewRowMeta)
|
void |
setRepartitioning(int repartitioning)
|
void |
setSafeModeEnabled(boolean safeModeEnabled)
|
void |
setServerSockets(List<ServerSocket> serverSockets)
|
void |
setSocketRepository(SocketRepository socketRepository)
|
void |
setStepDataInterface(StepDataInterface stepDataInterface)
|
void |
setStepListeners(List<StepListener> stepListeners)
|
void |
setStepMeta(StepMeta stepMeta)
|
void |
setStepMetaInterface(StepMetaInterface stepMetaInterface)
|
void |
setStepname(String stepname)
|
void |
setStopped(AtomicBoolean stopped)
|
void |
setStopped(boolean stopped)
|
void |
setTransMeta(TransMeta transMeta)
|
void |
setUsingThreadPriorityManagment(boolean usingThreadPriorityManagment)
|
void |
setVariable(String variableName,
String variableValue)
|
void |
shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
|
void |
stopAll()
Flags all rowsets as stopped/completed/finished. |
void |
stopRunning()
Deprecated. |
void |
stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Perform actions to stop a running step. |
String |
toString()
|
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, run, 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 |
---|
isAlive, run, start |
Field Detail |
---|
public static StepPluginMeta[] steps
public static final String[] category_order
public static final String[] statusDesc
public long linesRead
public long linesWritten
public long linesInput
public long linesOutput
public long linesUpdated
public long linesSkipped
public long linesRejected
public List<BaseStep> thr
public ArrayList<org.pentaho.di.core.RowSet> inputRowSets
public ArrayList<org.pentaho.di.core.RowSet> outputRowSets
public List<RemoteStep> remoteInputSteps
public List<RemoteStep> remoteOutputSteps
public org.pentaho.di.core.RowSet errorRowSet
public AtomicBoolean stopped
public AtomicBoolean paused
public boolean waiting
public boolean init
public boolean first
public boolean terminator
public List<Object[]> terminator_rows
Constructor Detail |
---|
public BaseStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
stepMeta
- The StepMeta object to run.stepDataInterface
- the data object to store temporary data, database connections, caches, result sets,
hashtables etc.copyNr
- The copynumber for this step.transMeta
- The TransInfo of which the step stepMeta is part of.trans
- The (running) transformation to obtain information shared among the steps.Method Detail |
---|
public boolean init(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
init
in interface StepInterface
smi
- The metadata to work withsdi
- The data to initializepublic void dispose(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
dispose
in interface StepInterface
smi
- The metadata to work withsdi
- The data to dispose ofpublic void cleanup()
StepInterface
cleanup
in interface StepInterface
public long getProcessed()
public void setCopy(int cop)
public int getCopy()
getCopy
in interface StepInterface
public long getErrors()
StepInterface
getErrors
in interface StepInterface
public void setErrors(long e)
StepInterface
setErrors
in interface StepInterface
e
- the number of errors to setpublic long getLinesRead()
getLinesRead
in interface StepInterface
public long incrementLinesRead()
public long decrementLinesRead()
public void setLinesRead(long newLinesReadValue)
newLinesReadValue
- the new number of lines read from previous stepspublic long getLinesInput()
getLinesInput
in interface StepInterface
public long incrementLinesInput()
public void setLinesInput(long newLinesInputValue)
newLinesInputValue
- the new number of lines read from an input source: database, file, socket, etc.public long getLinesOutput()
getLinesOutput
in interface StepInterface
public long incrementLinesOutput()
public void setLinesOutput(long newLinesOutputValue)
newLinesOutputValue
- the new number of lines written to an output target: database, file, socket, etc.public long getLinesWritten()
getLinesWritten
in interface StepInterface
public long incrementLinesWritten()
public long decrementLinesWritten()
public void setLinesWritten(long newLinesWrittenValue)
newLinesWrittenValue
- the new number of lines written to next stepspublic long getLinesUpdated()
getLinesUpdated
in interface StepInterface
public long incrementLinesUpdated()
public void setLinesUpdated(long newLinesUpdatedValue)
newLinesOutputValue
- the new number of lines updated in an output target: database, file, socket, etc.public long getLinesRejected()
getLinesRejected
in interface StepInterface
public long incrementLinesRejected()
public void setLinesRejected(long newLinesRejectedValue)
setLinesRejected
in interface StepInterface
newLinesRejectedValue
- lines number of lines rejected to an error handling steppublic long getLinesSkipped()
public long incrementLinesSkipped()
public void setLinesSkipped(long newLinesSkippedValue)
newLinesSkippedValue
- lines number of lines skippedpublic String getStepname()
StepInterface
getStepname
in interface StepInterface
public void setStepname(String stepname)
public Trans getDispatcher()
public String getStatusDescription()
public StepMetaInterface getStepMetaInterface()
public void setStepMetaInterface(StepMetaInterface stepMetaInterface)
stepMetaInterface
- The stepMetaInterface to set.public StepDataInterface getStepDataInterface()
public void setStepDataInterface(StepDataInterface stepDataInterface)
stepDataInterface
- The stepDataInterface to set.public StepMeta getStepMeta()
getStepMeta
in interface StepInterface
public void setStepMeta(StepMeta stepMeta)
stepMeta
- The stepMeta to set.public TransMeta getTransMeta()
public void setTransMeta(TransMeta transMeta)
transMeta
- The transMeta to set.public Trans getTrans()
public void putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) throws org.pentaho.di.core.exception.KettleStepException
putRow
in interface StepInterface
row
- The row to put to the destination rowset(s).rowMeta
- The row to send to the destinations steps
org.pentaho.di.core.exception.KettleStepException
public void putRowTo(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
rowMeta
- The row meta-data to put to the destination RowSet.row
- the data to put in the RowSetrowSet
- the RoWset to put the row into.
org.pentaho.di.core.exception.KettleStepException
- In case something unexpected goes wrongpublic void putError(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, long nrErrors, String errorDescriptions, String fieldNames, String errorCodes) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public Object[] getRow() throws org.pentaho.di.core.exception.KettleException
getRow
in interface StepInterface
org.pentaho.di.core.exception.KettleException
public static void safeModeChecking(org.pentaho.di.core.row.RowMetaInterface referenceRowMeta, org.pentaho.di.core.row.RowMetaInterface rowMeta) throws org.pentaho.di.core.exception.KettleRowException
org.pentaho.di.core.exception.KettleRowException
public Object[] getRowFrom(org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public org.pentaho.di.core.RowSet findInputRowSet(String sourceStep) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public org.pentaho.di.core.RowSet findInputRowSet(String from, int fromcopy, String to, int tocopy)
public org.pentaho.di.core.RowSet findOutputRowSet(String targetStep) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public org.pentaho.di.core.RowSet findOutputRowSet(String from, int fromcopy, String to, int tocopy)
from
- fromcopy
- to
- tocopy
-
public void setOutputDone()
StepInterface
setOutputDone
in interface StepInterface
public void dispatch()
public void logMinimal(String s)
public void logBasic(String s)
public void logError(String s)
public void logError(String s, Throwable e)
public void logDetailed(String s)
public void logDebug(String s)
public void logRowlevel(String s)
public int getNextClassNr()
public boolean outputIsDone()
public void stopAll()
StepInterface
stopAll
in interface StepInterface
public boolean isStopped()
isStopped
in interface StepInterface
public boolean isPaused()
public void setStopped(boolean stopped)
public void setStopped(AtomicBoolean stopped)
public void pauseRunning()
StepInterface
pauseRunning
in interface StepInterface
public void resumeRunning()
StepInterface
resumeRunning
in interface StepInterface
public void setPaused(boolean paused)
public void setPaused(AtomicBoolean paused)
public boolean isInitialising()
public void markStart()
StepInterface
markStart
in interface StepInterface
public void setInternalVariables()
public void markStop()
StepInterface
markStop
in interface StepInterface
public long getRuntime()
public org.pentaho.di.core.RowMetaAndData buildLog(String sname, int copynr, long lines_read, long lines_written, long lines_updated, long lines_skipped, long errors, Date start_date, Date end_date)
public static final org.pentaho.di.core.row.RowMetaInterface getLogFields(String comm)
public String toString()
toString
in class Thread
public Thread getThread()
public int rowsetOutputSize()
public int rowsetInputSize()
public static final StepMetaInterface getStepInfo(StepPlugin stepplugin, StepLoader steploader) throws org.pentaho.di.core.exception.KettleStepLoaderException
stepplugin
- The step/plugin to usesteploader
- The StepLoader to load from
org.pentaho.di.core.exception.KettleStepLoaderException
public static final String getIconFilename(int steptype)
public void stopRunning(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface) throws org.pentaho.di.core.exception.KettleException
stopRunning
in interface StepInterface
stepDataInterface
- The interface to the step data containing the connections, resultsets, open files, etc.stepMetaInterface
- The metadata that might be needed by the step to stop running.
org.pentaho.di.core.exception.KettleException
- in case something goes wrongpublic void stopRunning()
public void logSummary()
public String getStepID()
getStepID
in interface StepInterface
public List<org.pentaho.di.core.RowSet> getInputRowSets()
getInputRowSets
in interface StepInterface
public void setInputRowSets(ArrayList<org.pentaho.di.core.RowSet> inputRowSets)
inputRowSets
- The inputRowSets to set.public List<org.pentaho.di.core.RowSet> getOutputRowSets()
getOutputRowSets
in interface StepInterface
public void setOutputRowSets(ArrayList<org.pentaho.di.core.RowSet> outputRowSets)
outputRowSets
- The outputRowSets to set.public boolean isDistributed()
public void setDistributed(boolean distributed)
distributed
- The distributed to set.public void addRowListener(RowListener rowListener)
StepInterface
addRowListener
in interface StepInterface
rowListener
- the rowlistener to addpublic void removeRowListener(RowListener rowListener)
StepInterface
removeRowListener
in interface StepInterface
rowListener
- the rowlistener to removepublic List<RowListener> getRowListeners()
getRowListeners
in interface StepInterface
public void addResultFile(org.pentaho.di.core.ResultFile resultFile)
public Map<String,org.pentaho.di.core.ResultFile> getResultFiles()
public boolean isSafeModeEnabled()
public void setSafeModeEnabled(boolean safeModeEnabled)
safeModeEnabled
- set to true is this step has to be running in safe mode, with extra checking enabled...public int getStatus()
public String getPartitionID()
getPartitionID
in interface StepInterface
public void setPartitionID(String partitionID)
setPartitionID
in interface StepInterface
partitionID
- the partitionID to setpublic Map<String,org.pentaho.di.core.RowSet> getPartitionTargets()
public void setPartitionTargets(Map<String,org.pentaho.di.core.RowSet> partitionTargets)
partitionTargets
- the partitionTargets to setpublic int getRepartitioning()
public void setRepartitioning(int repartitioning)
repartitioning
- the repartitioning type to setpublic boolean isPartitioned()
isPartitioned
in interface StepInterface
public void setPartitioned(boolean partitioned)
partitioned
- the partitioned to setpublic org.pentaho.di.core.row.RowMetaInterface getInputRowMeta()
public void setInputRowMeta(org.pentaho.di.core.row.RowMetaInterface rowMeta)
rowMeta
- the rowMeta to setpublic org.pentaho.di.core.row.RowMetaInterface getErrorRowMeta()
public void setErrorRowMeta(org.pentaho.di.core.row.RowMetaInterface errorRowMeta)
errorRowMeta
- the errorRowMeta to setpublic org.pentaho.di.core.row.RowMetaInterface getPreviewRowMeta()
public void setPreviewRowMeta(org.pentaho.di.core.row.RowMetaInterface previewRowMeta)
previewRowMeta
- the previewRowMeta to setpublic 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[] aString)
environmentSubstitute
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 boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
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 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 void injectVariables(Map<String,String> prop)
injectVariables
in interface org.pentaho.di.core.variables.VariableSpace
public String getTypeId()
public int getSlaveNr()
public int getClusterSize()
public int getUniqueStepNrAcrossSlaves()
public int getUniqueStepCountAcrossSlaves()
public List<ServerSocket> getServerSockets()
public void setServerSockets(List<ServerSocket> serverSockets)
serverSockets
- the serverSockets to setpublic void setUsingThreadPriorityManagment(boolean usingThreadPriorityManagment)
usingThreadPriorityManagment
- set to true to actively manage priorities of step threadspublic boolean isUsingThreadPriorityManagment()
public void initBeforeStart() throws org.pentaho.di.core.exception.KettleStepException
initBeforeStart
in interface StepInterface
org.pentaho.di.core.exception.KettleStepException
- In case there is an errorpublic static void runStepThread(StepInterface stepInterface, StepMetaInterface meta, StepDataInterface data)
public List<StepListener> getStepListeners()
public void setStepListeners(List<StepListener> stepListeners)
stepListeners
- the stepListeners to setpublic boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
StepInterface
processRow
in interface StepInterface
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 addStepListener(StepListener stepListener)
StepInterface
addStepListener
in interface StepInterface
stepListener
- The listener to add to the steppublic boolean isMapping()
isMapping
in interface StepInterface
public SocketRepository getSocketRepository()
public void setSocketRepository(SocketRepository socketRepository)
socketRepository
- the socketRepository to set
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |