public class CollectionReader<T> extends DataReader
DataEndpoint.StatefieldLineage, recordLineagelastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEYBUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZEid, log, name, TIMESTAMP_FORMAT| Constructor and Description |
|---|
CollectionReader(Collection<T> collection,
Function<T,Record> recordConverterFunction) |
CollectionReader(Iterator<T> iterator,
Function<T,Record> recordConverterFunction) |
CollectionReader(Stream<T> stream,
Function<T,Record> recordConverterFunction) |
| Modifier and Type | Method and Description |
|---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException. |
protected Record |
elementToRecord(T nextElement) |
protected Collection<T> |
getCollection() |
protected Iterator<T> |
getIterator() |
protected Function<T,Record> |
getRecordConverterFunction() |
protected Record |
readImpl()
Overridden by subclasses to read the next record from this
DataReader. |
addLineage, available, getBufferSize, getNestedEndpoint, getNestedReader, getReader, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skipclose, decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, open, resetRecordCount, toStringaddElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescriptionpublic CollectionReader(Collection<T> collection, Function<T,Record> recordConverterFunction)
public CollectionReader(Iterator<T> iterator, Function<T,Record> recordConverterFunction)
protected Record readImpl() throws Throwable
DataReaderDataReader. 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 DataReaderThrowableprotected Collection<T> getCollection()
public DataException addExceptionProperties(DataException exception)
EndpointDataException. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties in class DataReaderCopyright (c) 2006-2025 North Concepts Inc. All Rights Reserved.