public class AsyncTaskReader extends ProxyReader
DataReaderDecorator.
This reader creates the number of threads specified, divides the incoming data amongst the thread evenly, and decorates each thread's reader with the specified task.DataEndpoint.StatefieldLineage, recordLineagelastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEYBUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZEid, log, name, TIMESTAMP_FORMAT| Constructor and Description |
|---|
AsyncTaskReader(DataReader input,
DataReaderDecorator task,
int threads)
Creates a new AsyncTaskReader to process incoming data using multiple threads.
|
| 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.
|
DataReaderDecorator |
getTask() |
int |
getThreads() |
void |
open()
Makes this endpoint ready for reading or writing.
|
protected Record |
readImpl()
Overridden by subclasses to read the next record from this
DataReader. |
available, getNestedReader, interceptRecord, map, map, setNestedDataReader, setNestedDataReaderaddLineage, getBufferSize, getNestedEndpoint, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skipdecrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toStringaddElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescriptionpublic AsyncTaskReader(DataReader input, DataReaderDecorator task, int threads)
input - The incoming data stream to processtask - The work to apply to the incoming datathreads - The number of threads to use to process the incoming datapublic DataReaderDecorator getTask()
public int getThreads()
public void open()
throws DataException
DataEndpointopen in class ProxyReaderDataExceptionpublic void close()
throws DataException
DataEndpointclose in class ProxyReaderDataExceptionprotected 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 ProxyReaderThrowablepublic 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 ProxyReaderCopyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.