org.pentaho.di.trans.steps.textfileinput
Class TextFileInput
java.lang.Object
java.lang.Thread
org.pentaho.di.trans.step.BaseStep
org.pentaho.di.trans.steps.textfileinput.TextFileInput
- All Implemented Interfaces:
- Runnable, org.pentaho.di.core.variables.VariableSpace, StepInterface
public class TextFileInput
- extends BaseStep
- implements StepInterface
Read all sorts of text files, convert them to rows and writes these to one or
more output streams.
- Since:
- 4-apr-2003
- Author:
- Matt
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 |
Method Summary |
static Object[] |
convertLineToRow(TextFileLine textFileLine,
InputFileMetaInterface info,
Object[] passThruFields,
int nrPassThruFields,
org.pentaho.di.core.row.RowMetaInterface outputRowMeta,
org.pentaho.di.core.row.RowMetaInterface convertRowMeta,
String fname,
long rowNr,
FileErrorHandler errorHandler)
|
static Object[] |
convertLineToRow(TextFileLine textFileLine,
InputFileMetaInterface info,
org.pentaho.di.core.row.RowMetaInterface outputRowMeta,
org.pentaho.di.core.row.RowMetaInterface convertRowMeta,
String fname,
long rowNr,
FileErrorHandler errorHandler)
Deprecated. Use convertLineToRow(TextFileLine,InputFileMetaInterface,Object[],int,RowMetaInterface,RowMetaInterface,String,long, FileErrorHandler) instead |
static String[] |
convertLineToStrings(String line,
InputFileMetaInterface inf)
|
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
static String |
getLine(org.pentaho.di.core.logging.LogWriter log,
InputStreamReader reader,
int formatNr,
StringBuilder line)
|
static String[] |
guessStringsFromLine(String line,
TextFileInputMeta inf)
|
boolean |
init(StepMetaInterface smi,
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... |
Methods inherited from class org.pentaho.di.trans.step.BaseStep |
addResultFile, addRowListener, addStepListener, buildLog, cleanup, copyVariablesFrom, decrementLinesRead, decrementLinesWritten, dispatch, environmentSubstitute, environmentSubstitute, findInputRowSet, findInputRowSet, findOutputRowSet, findOutputRowSet, getBooleanValueOfVariable, getClusterSize, getCopy, getDispatcher, getErrorRowMeta, getErrors, getIconFilename, getInputRowMeta, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesSkipped, getLinesUpdated, getLinesWritten, getLogFields, getNextClassNr, getOutputRowSets, getParentVariableSpace, getPartitionID, getPartitionTargets, getPreviewRowMeta, getProcessed, getRepartitioning, getResultFiles, getRow, getRowFrom, getRowListeners, getRuntime, getServerSockets, getSlaveNr, getSocketRepository, getStatus, getStatusDescription, getStepDataInterface, getStepID, getStepInfo, getStepListeners, getStepMeta, getStepMetaInterface, getStepname, getThread, getTrans, getTransMeta, getTypeId, getUniqueStepCountAcrossSlaves, getUniqueStepNrAcrossSlaves, getVariable, getVariable, incrementLinesInput, incrementLinesOutput, incrementLinesRead, incrementLinesRejected, incrementLinesSkipped, incrementLinesUpdated, incrementLinesWritten, initBeforeStart, initializeVariablesFrom, injectVariables, isDistributed, isInitialising, isMapping, isPartitioned, isPaused, isSafeModeEnabled, isStopped, isUsingThreadPriorityManagment, listVariables, logBasic, logDebug, logDetailed, logError, logError, logMinimal, logRowlevel, logSummary, markStart, markStop, outputIsDone, pauseRunning, putError, putRow, putRowTo, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, runStepThread, safeModeChecking, setCopy, setDistributed, setErrorRowMeta, setErrors, setInputRowMeta, setInputRowSets, setInternalVariables, setLinesInput, setLinesOutput, setLinesRead, setLinesRejected, setLinesSkipped, setLinesUpdated, setLinesWritten, setOutputDone, setOutputRowSets, setParentVariableSpace, setPartitioned, setPartitionID, setPartitionTargets, setPaused, setPaused, setPreviewRowMeta, setRepartitioning, setSafeModeEnabled, setServerSockets, setSocketRepository, setStepDataInterface, setStepListeners, setStepMeta, setStepMetaInterface, setStepname, setStopped, setStopped, setTransMeta, setUsingThreadPriorityManagment, setVariable, shareVariablesWith, stopAll, stopRunning, stopRunning, 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, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
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 |
TextFileInput
public TextFileInput(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
getLine
public static final String getLine(org.pentaho.di.core.logging.LogWriter log,
InputStreamReader reader,
int formatNr,
StringBuilder line)
throws org.pentaho.di.core.exception.KettleFileException
- Throws:
org.pentaho.di.core.exception.KettleFileException
guessStringsFromLine
public static final String[] guessStringsFromLine(String line,
TextFileInputMeta inf)
throws org.pentaho.di.core.exception.KettleException
- Throws:
org.pentaho.di.core.exception.KettleException
convertLineToStrings
public static final String[] convertLineToStrings(String line,
InputFileMetaInterface inf)
throws org.pentaho.di.core.exception.KettleException
- Throws:
org.pentaho.di.core.exception.KettleException
convertLineToRow
public static final Object[] convertLineToRow(TextFileLine textFileLine,
InputFileMetaInterface info,
org.pentaho.di.core.row.RowMetaInterface outputRowMeta,
org.pentaho.di.core.row.RowMetaInterface convertRowMeta,
String fname,
long rowNr,
FileErrorHandler errorHandler)
throws org.pentaho.di.core.exception.KettleException
- Deprecated. Use
convertLineToRow(TextFileLine,InputFileMetaInterface,Object[],int,RowMetaInterface,RowMetaInterface,String,long, FileErrorHandler)
instead
- Throws:
org.pentaho.di.core.exception.KettleException
convertLineToRow
public static final Object[] convertLineToRow(TextFileLine textFileLine,
InputFileMetaInterface info,
Object[] passThruFields,
int nrPassThruFields,
org.pentaho.di.core.row.RowMetaInterface outputRowMeta,
org.pentaho.di.core.row.RowMetaInterface convertRowMeta,
String fname,
long rowNr,
FileErrorHandler errorHandler)
throws org.pentaho.di.core.exception.KettleException
- Throws:
org.pentaho.di.core.exception.KettleException
processRow
public boolean processRow(StepMetaInterface smi,
StepDataInterface sdi)
throws org.pentaho.di.core.exception.KettleException
- Description copied from interface:
StepInterface
- Process one row.
- Specified by:
processRow
in interface StepInterface
- Overrides:
processRow
in class BaseStep
- Parameters:
smi
- The metadata to work withsdi
- The temporary working data to work with (database connections, resultsets, caches, temporary variables, etc.)
- Returns:
- false if no more rows can be processed or an error occurred.
- Throws:
org.pentaho.di.core.exception.KettleException
init
public boolean init(StepMetaInterface smi,
StepDataInterface sdi)
- Description copied from interface:
StepInterface
- Initialise and do work where other steps need to wait for...
- Specified by:
init
in interface StepInterface
- Overrides:
init
in class BaseStep
- Parameters:
smi
- The metadata to work withsdi
- The data to initialize
dispose
public void dispose(StepMetaInterface smi,
StepDataInterface sdi)
- Description copied from interface:
StepInterface
- Dispose of this step: close files, empty logs, etc.
- Specified by:
dispose
in interface StepInterface
- Overrides:
dispose
in class BaseStep
- Parameters:
smi
- The metadata to work withsdi
- The data to dispose of
run
public void run()
- Description copied from interface:
StepInterface
- Run is where the action happens in a step...
- Specified by:
run
in interface Runnable
- Specified by:
run
in interface StepInterface
- Overrides:
run
in class Thread