Package org.pentaho.di.trans.steps.fileinput.text

Class TextFileInputReader

java.lang.Object

org.pentaho.di.trans.steps.fileinput.text.TextFileInputReader

All Implemented Interfaces:

Closeable, AutoCloseable, IBaseFileInputReader

public class TextFileInputReader
extends Object
implements IBaseFileInputReader

Reader for one text file.

Author:

Alexander Buloichik

Field Summary

Fields

Modifier and Type	Field	Description
protected long	lineInFile
protected long	lineNumberInFile
protected long	linesWritten

Constructor Summary

Constructors

Constructor	Description
TextFileInputReader(IBaseFileInputStepControl step, TextFileInputMeta meta, TextFileInputData data, org.apache.commons.vfs2.FileObject file, org.pentaho.di.core.logging.LogChannelInterface log)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	readInitial()
boolean	readRow()
protected boolean	tryToReadLine(boolean applyFilter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

lineInFile

protected long lineInFile

lineNumberInFile

protected long lineNumberInFile

linesWritten

protected long linesWritten

Constructor Details

TextFileInputReader

public TextFileInputReader(IBaseFileInputStepControl step,
 TextFileInputMeta meta,
 TextFileInputData data,
 org.apache.commons.vfs2.FileObject file,
 org.pentaho.di.core.logging.LogChannelInterface log)
                    throws Exception

Throws:

Exception

Method Details

readInitial

protected void readInitial()
                    throws Exception

Throws:

Exception

readRow

public boolean readRow()
                throws org.pentaho.di.core.exception.KettleException

Specified by:

readRow in interface IBaseFileInputReader

Throws:

org.pentaho.di.core.exception.KettleException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

tryToReadLine

protected boolean tryToReadLine(boolean applyFilter)
                         throws org.pentaho.di.core.exception.KettleFileException

Throws:

org.pentaho.di.core.exception.KettleFileException