public abstract class TransformClassBase extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TransformClassBase.Fields |
Constructor and Description |
---|
TransformClassBase(UserDefinedJavaClass parent,
UserDefinedJavaClassMeta meta,
UserDefinedJavaClassData data) |
Modifier and Type | Method and Description |
---|---|
void |
addResultFile(org.pentaho.di.core.ResultFile resultFile) |
void |
addRowListener(RowListener rowListener) |
void |
addStepListener(StepListener stepListener) |
boolean |
checkFeedback(long lines) |
void |
cleanup() |
Object[] |
createOutputRow(Object[] inputRow,
int outputRowSize) |
long |
decrementLinesRead() |
long |
decrementLinesWritten() |
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi) |
org.pentaho.di.core.RowSet |
findInfoRowSet(String tag) |
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) |
org.pentaho.di.core.RowSet |
findTargetRowSet(String tag) |
FieldHelper |
get(TransformClassBase.Fields type,
String name) |
int |
getClusterSize() |
int |
getCopy() |
org.pentaho.di.core.row.RowMetaInterface |
getErrorRowMeta() |
long |
getErrors() |
static void |
getFields(boolean clearResultFields,
org.pentaho.di.core.row.RowMetaInterface row,
String originStepname,
org.pentaho.di.core.row.RowMetaInterface[] info,
StepMeta nextStep,
org.pentaho.di.core.variables.VariableSpace space,
List<?> fields) |
static String[] |
getInfoSteps() |
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() |
List<org.pentaho.di.core.RowSet> |
getOutputRowSets() |
String |
getParameter(String tag) |
String |
getPartitionID() |
Map<String,org.pentaho.di.core.BlockingRowSet> |
getPartitionTargets() |
long |
getProcessed() |
int |
getRepartitioning() |
Map<String,org.pentaho.di.core.ResultFile> |
getResultFiles() |
Object[] |
getRow() |
Object[] |
getRowFrom(org.pentaho.di.core.RowSet rowSet) |
List<RowListener> |
getRowListeners() |
long |
getRuntime() |
int |
getSlaveNr() |
SocketRepository |
getSocketRepository() |
BaseStepData.StepExecutionStatus |
getStatus() |
String |
getStatusDescription() |
StepDataInterface |
getStepDataInterface() |
String |
getStepID() |
static StepIOMetaInterface |
getStepIOMeta(UserDefinedJavaClassMeta meta) |
List<StepListener> |
getStepListeners() |
StepMeta |
getStepMeta() |
String |
getStepname() |
Trans |
getTrans() |
TransMeta |
getTransMeta() |
String |
getTypeId() |
int |
getUniqueStepCountAcrossSlaves() |
int |
getUniqueStepNrAcrossSlaves() |
String |
getVariable(String variableName) |
String |
getVariable(String variableName,
String defaultValue) |
long |
incrementLinesInput() |
long |
incrementLinesOutput() |
long |
incrementLinesRead() |
long |
incrementLinesRejected() |
long |
incrementLinesSkipped() |
long |
incrementLinesUpdated() |
long |
incrementLinesWritten() |
boolean |
init(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface) |
void |
initBeforeStart() |
boolean |
isDistributed() |
boolean |
isInitialising() |
boolean |
isPartitioned() |
boolean |
isSafeModeEnabled() |
boolean |
isStopped() |
boolean |
isUsingThreadPriorityManagment() |
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() |
void |
markStop() |
void |
openRemoteInputStepSocketsOnce() |
void |
openRemoteOutputStepSocketsOnce() |
boolean |
outputIsDone() |
abstract boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi) |
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 row,
Object[] data) |
void |
putRowTo(org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] row,
org.pentaho.di.core.RowSet rowSet) |
void |
removeRowListener(RowListener rowListener) |
int |
rowsetInputSize() |
int |
rowsetOutputSize() |
void |
safeModeChecking(org.pentaho.di.core.row.RowMetaInterface row) |
void |
setErrors(long errors) |
void |
setInputRowMeta(org.pentaho.di.core.row.RowMetaInterface rowMeta) |
void |
setInputRowSets(List<org.pentaho.di.core.RowSet> inputRowSets) |
void |
setLinesInput(long newLinesInputValue) |
void |
setLinesOutput(long newLinesOutputValue) |
void |
setLinesRead(long newLinesReadValue) |
void |
setLinesRejected(long linesRejected) |
void |
setLinesSkipped(long newLinesSkippedValue) |
void |
setLinesUpdated(long newLinesUpdatedValue) |
void |
setLinesWritten(long newLinesWrittenValue) |
void |
setOutputDone() |
void |
setOutputRowSets(List<org.pentaho.di.core.RowSet> outputRowSets) |
void |
setStepListeners(List<StepListener> stepListeners) |
void |
setVariable(String variableName,
String variableValue) |
void |
stopAll() |
void |
stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface) |
String |
toString() |
public TransformClassBase(UserDefinedJavaClass parent, UserDefinedJavaClassMeta meta, UserDefinedJavaClassData data) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public void addResultFile(org.pentaho.di.core.ResultFile resultFile)
public void addRowListener(RowListener rowListener)
public void addStepListener(StepListener stepListener)
public boolean checkFeedback(long lines)
public void cleanup()
public long decrementLinesRead()
public long decrementLinesWritten()
public void dispose(StepMetaInterface smi, StepDataInterface sdi)
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)
public int getClusterSize()
public int getCopy()
public org.pentaho.di.core.row.RowMetaInterface getErrorRowMeta()
public long getErrors()
public org.pentaho.di.core.row.RowMetaInterface getInputRowMeta()
public List<org.pentaho.di.core.RowSet> getInputRowSets()
public long getLinesInput()
public long getLinesOutput()
public long getLinesRead()
public long getLinesRejected()
public long getLinesSkipped()
public long getLinesUpdated()
public long getLinesWritten()
public List<org.pentaho.di.core.RowSet> getOutputRowSets()
public String getPartitionID()
public long getProcessed()
public int getRepartitioning()
public Object[] getRow() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public Object[] getRowFrom(org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public List<RowListener> getRowListeners()
public long getRuntime()
public int getSlaveNr()
public SocketRepository getSocketRepository()
public BaseStepData.StepExecutionStatus getStatus()
public String getStatusDescription()
public StepDataInterface getStepDataInterface()
public String getStepID()
public List<StepListener> getStepListeners()
public StepMeta getStepMeta()
public String getStepname()
public Trans getTrans()
public TransMeta getTransMeta()
public String getTypeId()
public int getUniqueStepCountAcrossSlaves()
public int getUniqueStepNrAcrossSlaves()
public long incrementLinesInput()
public long incrementLinesOutput()
public long incrementLinesRead()
public long incrementLinesRejected()
public long incrementLinesSkipped()
public long incrementLinesUpdated()
public long incrementLinesWritten()
public boolean init(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface)
public void initBeforeStart() throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public boolean isDistributed()
public boolean isInitialising()
public boolean isPartitioned()
public boolean isSafeModeEnabled()
public boolean isStopped()
public boolean isUsingThreadPriorityManagment()
public void logBasic(String s)
public void logDebug(String s)
public void logDetailed(String s)
public void logError(String s)
public void logMinimal(String s)
public void logRowlevel(String s)
public void logSummary()
public void markStart()
public void markStop()
public void openRemoteInputStepSocketsOnce() throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public void openRemoteOutputStepSocketsOnce() throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public boolean outputIsDone()
public abstract boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public 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 void putRow(org.pentaho.di.core.row.RowMetaInterface row, Object[] data) throws org.pentaho.di.core.exception.KettleStepException
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
org.pentaho.di.core.exception.KettleStepException
public void removeRowListener(RowListener rowListener)
public int rowsetInputSize()
public int rowsetOutputSize()
public void safeModeChecking(org.pentaho.di.core.row.RowMetaInterface row) throws org.pentaho.di.core.exception.KettleRowException
org.pentaho.di.core.exception.KettleRowException
public void setErrors(long errors)
public void setInputRowMeta(org.pentaho.di.core.row.RowMetaInterface rowMeta)
public void setInputRowSets(List<org.pentaho.di.core.RowSet> inputRowSets)
public void setLinesInput(long newLinesInputValue)
public void setLinesOutput(long newLinesOutputValue)
public void setLinesRead(long newLinesReadValue)
public void setLinesRejected(long linesRejected)
public void setLinesSkipped(long newLinesSkippedValue)
public void setLinesUpdated(long newLinesUpdatedValue)
public void setLinesWritten(long newLinesWrittenValue)
public void setOutputDone()
public void setOutputRowSets(List<org.pentaho.di.core.RowSet> outputRowSets)
public void setStepListeners(List<StepListener> stepListeners)
public void stopAll()
public void stopRunning(StepMetaInterface stepMetaInterface, StepDataInterface stepDataInterface) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public static String[] getInfoSteps()
public static void getFields(boolean clearResultFields, org.pentaho.di.core.row.RowMetaInterface row, String originStepname, org.pentaho.di.core.row.RowMetaInterface[] info, StepMeta nextStep, org.pentaho.di.core.variables.VariableSpace space, List<?> fields) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
public static StepIOMetaInterface getStepIOMeta(UserDefinedJavaClassMeta meta)
public org.pentaho.di.core.RowSet findInfoRowSet(String tag) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowSet findTargetRowSet(String tag) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public FieldHelper get(TransformClassBase.Fields type, String name) throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException