public class FileReader extends DataReader
FileWriter
.DataEndpoint.State
fieldLineage, recordLineage
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
FileReader(DataInput in) |
FileReader(File file) |
FileReader(File file,
boolean compressed) |
FileReader(InputStream inputStream,
boolean compressed) |
Modifier and Type | Method and Description |
---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
void |
close()
Indicates that this endpoint has finished reading or writing.
|
boolean |
isAutoCloseReader()
Indicates if the underlying input stream should be closed when this stream closes (defaults to true).
|
boolean |
isAutoCloseWriter()
Deprecated.
use
isAutoCloseReader() instead.
Indicates if the underlying input stream should be closed when this stream closes (defaults to true). |
boolean |
isCompressed()
Indicates if the data is compressed and should be decompressed as it is being read.
|
static Record |
read(DataInput in,
Record record) |
protected Record |
readImpl()
Overridden by subclasses to read the next record from this
DataReader . |
FileReader |
setAutoCloseReader(boolean autoCloseReader)
Indicates if the underlying input stream should be closed when this stream closes (defaults to true).
|
FileReader |
setAutoCloseWriter(boolean autoCloseWriter)
Deprecated.
use
setAutoCloseReader(boolean) instead.
Indicates if the underlying input stream should be closed when this stream closes (defaults to true). |
addLineage, available, getBufferSize, getNestedEndpoint, getNestedReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, open, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
public FileReader(File file, boolean compressed)
file
- the file to read.compressed
- Indicates if the data is compressed and should be decompressed as it is being read.public FileReader(InputStream inputStream, boolean compressed)
compressed
- Indicates if the data is compressed and should be decompressed as it is being read.public FileReader(File file)
public FileReader(DataInput in)
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class DataReader
public boolean isAutoCloseReader()
public FileReader setAutoCloseReader(boolean autoCloseReader)
@Deprecated public boolean isAutoCloseWriter()
isAutoCloseReader()
instead.
Indicates if the underlying input stream should be closed when this stream closes (defaults to true).@Deprecated public FileReader setAutoCloseWriter(boolean autoCloseWriter)
setAutoCloseReader(boolean)
instead.
Indicates if the underlying input stream should be closed when this stream closes (defaults to true).public boolean isCompressed()
public void close()
DataEndpoint
close
in class DataEndpoint
protected Record readImpl() throws Throwable
DataReader
DataReader
. The default
implementation of DataReader.read()
now insures that this method will not be called again after it returns
a null
.
If no record is available, null
will be returned.
readImpl
in class DataReader
Throwable
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.