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

Class TextFileInputUtils

java.lang.Object

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

public class TextFileInputUtils
extends Object

Some common methods for text file parsing.

Author:

Alexander Buloichik

Constructor Summary

Constructors

Constructor and Description
TextFileInputUtils()

Method Summary

Modifier and Type	Method and Description
static Object[]	convertLineToRow(LogChannelInterface log, TextFileLine textFileLine, TextFileInputMeta info, Object[] passThruFields, int nrPassThruFields, RowMetaInterface outputRowMeta, RowMetaInterface convertRowMeta, String fname, long rowNr, String delimiter, String enclosure, String escapeCharacter, FileErrorHandler errorHandler, BaseFileInputAdditionalField additionalOutputFields, String shortFilename, String path, boolean hidden, Date modificationDateTime, String uri, String rooturi, String extension, Long size)
static Object[]	convertLineToRow(LogChannelInterface log, TextFileLine textFileLine, TextFileInputMeta info, Object[] passThruFields, int nrPassThruFields, RowMetaInterface outputRowMeta, RowMetaInterface convertRowMeta, String fname, long rowNr, String delimiter, String enclosure, String escapeCharacter, FileErrorHandler errorHandler, BaseFileInputAdditionalField additionalOutputFields, String shortFilename, String path, boolean hidden, Date modificationDateTime, String uri, String rooturi, String extension, Long size, boolean failOnParseError)
static String[]	convertLineToStrings(LogChannelInterface log, String line, TextFileInputMeta inf, String delimiter, String enclosure, String escapeCharacters)
static String	getLine(LogChannelInterface log, InputStreamReader reader, EncodingType encodingType, int formatNr, StringBuilder line)
static String	getLine(LogChannelInterface log, InputStreamReader reader, int formatNr, StringBuilder line)
static String[]	guessStringsFromLine(VariableSpace space, LogChannelInterface log, String line, TextFileInputMeta inf, String delimiter, String enclosure, String escapeCharacter)

Methods inherited from class java.lang.Object

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

Constructor Detail

TextFileInputUtils

public TextFileInputUtils()

Method Detail

guessStringsFromLine

public static final String[] guessStringsFromLine(VariableSpace space,
                                                  LogChannelInterface log,
                                                  String line,
                                                  TextFileInputMeta inf,
                                                  String delimiter,
                                                  String enclosure,
                                                  String escapeCharacter)
                                           throws KettleException

Throws:

KettleException

getLine

public static final String getLine(LogChannelInterface log,
                                   InputStreamReader reader,
                                   int formatNr,
                                   StringBuilder line)
                            throws KettleFileException

Throws:

KettleFileException

getLine

public static final String getLine(LogChannelInterface log,
                                   InputStreamReader reader,
                                   EncodingType encodingType,
                                   int formatNr,
                                   StringBuilder line)
                            throws KettleFileException

Throws:

KettleFileException

convertLineToRow

public static final Object[] convertLineToRow(LogChannelInterface log,
                                              TextFileLine textFileLine,
                                              TextFileInputMeta info,
                                              Object[] passThruFields,
                                              int nrPassThruFields,
                                              RowMetaInterface outputRowMeta,
                                              RowMetaInterface convertRowMeta,
                                              String fname,
                                              long rowNr,
                                              String delimiter,
                                              String enclosure,
                                              String escapeCharacter,
                                              FileErrorHandler errorHandler,
                                              BaseFileInputAdditionalField additionalOutputFields,
                                              String shortFilename,
                                              String path,
                                              boolean hidden,
                                              Date modificationDateTime,
                                              String uri,
                                              String rooturi,
                                              String extension,
                                              Long size)
                                       throws KettleException

Throws:

KettleException

convertLineToRow

public static final Object[] convertLineToRow(LogChannelInterface log,
                                              TextFileLine textFileLine,
                                              TextFileInputMeta info,
                                              Object[] passThruFields,
                                              int nrPassThruFields,
                                              RowMetaInterface outputRowMeta,
                                              RowMetaInterface convertRowMeta,
                                              String fname,
                                              long rowNr,
                                              String delimiter,
                                              String enclosure,
                                              String escapeCharacter,
                                              FileErrorHandler errorHandler,
                                              BaseFileInputAdditionalField additionalOutputFields,
                                              String shortFilename,
                                              String path,
                                              boolean hidden,
                                              Date modificationDateTime,
                                              String uri,
                                              String rooturi,
                                              String extension,
                                              Long size,
                                              boolean failOnParseError)
                                       throws KettleException

Parameters:

failOnParseError - if set to true, parsing failure on any line will cause parsing to be terminated; when set to false, parsing failure on a given line will not prevent remaining lines from being parsed - this allows us to analyze fields, even if some field is mis-configured and causes a parsing error for the values of that field.

Throws:

KettleException

convertLineToStrings

public static final String[] convertLineToStrings(LogChannelInterface log,
                                                  String line,
                                                  TextFileInputMeta inf,
                                                  String delimiter,
                                                  String enclosure,
                                                  String escapeCharacters)
                                           throws KettleException

Throws:

KettleException