All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
addResultFile(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) |
RowSet |
findInfoRowSet(String tag) |
RowSet |
findInputRowSet(String sourceStep) |
RowSet |
findInputRowSet(String from,
int fromcopy,
String to,
int tocopy) |
RowSet |
findOutputRowSet(String targetStep) |
RowSet |
findOutputRowSet(String from,
int fromcopy,
String to,
int tocopy) |
RowSet |
findTargetRowSet(String tag) |
FieldHelper |
get(TransformClassBase.Fields type,
String name) |
int |
getClusterSize() |
int |
getCopy() |
RowMetaInterface |
getErrorRowMeta() |
long |
getErrors() |
static void |
getFields(boolean clearResultFields,
RowMetaInterface row,
String originStepname,
RowMetaInterface[] info,
StepMeta nextStep,
VariableSpace space,
List<?> fields) |
static String[] |
getInfoSteps() |
RowMetaInterface |
getInputRowMeta() |
List<RowSet> |
getInputRowSets() |
long |
getLinesInput() |
long |
getLinesOutput() |
long |
getLinesRead() |
long |
getLinesRejected() |
long |
getLinesSkipped() |
long |
getLinesUpdated() |
long |
getLinesWritten() |
List<RowSet> |
getOutputRowSets() |
String |
getParameter(String tag) |
String |
getPartitionID() |
Map<String,BlockingRowSet> |
getPartitionTargets() |
long |
getProcessed() |
int |
getRepartitioning() |
Map<String,ResultFile> |
getResultFiles() |
Object[] |
getRow() |
Object[] |
getRowFrom(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(RowMetaInterface rowMeta,
Object[] row,
long nrErrors,
String errorDescriptions,
String fieldNames,
String errorCodes) |
void |
putRow(RowMetaInterface row,
Object[] data) |
void |
putRowTo(RowMetaInterface rowMeta,
Object[] row,
RowSet rowSet) |
void |
removeRowListener(RowListener rowListener) |
int |
rowsetInputSize() |
int |
rowsetOutputSize() |
void |
safeModeChecking(RowMetaInterface row) |
void |
setErrors(long errors) |
void |
setInputRowMeta(RowMetaInterface rowMeta) |
void |
setInputRowSets(List<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<RowSet> outputRowSets) |
void |
setStepListeners(List<StepListener> stepListeners) |
void |
setVariable(String variableName,
String variableValue) |
void |
stopAll() |
void |
stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface) |
String |
toString() |