com.northconcepts.datapipeline.core

Class SortingReader

java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.core.Endpoint

com.northconcepts.datapipeline.core.DataEndpoint

com.northconcepts.datapipeline.core.DataReader

com.northconcepts.datapipeline.core.ProxyReader

com.northconcepts.datapipeline.core.SortingReader

public class SortingReader
extends ProxyReader

A proxy that sorts records.

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

DataEndpoint.State

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataReader

fieldLineage, recordLineage

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
SortingReader(DataReader reader)
SortingReader(DataReader reader, long bufferSize)

Method Summary

Modifier and Type	Method and Description
SortingReader	add(String fieldName)
SortingReader	add(String fieldName, boolean ascending)
SortingReader	add(String fieldName, boolean ascending, Collator collator)
SortingReader	asc(String fieldName)
void	close() Indicates that this endpoint has finished reading or writing.
static void	copy(DataReader source, DataWriter sink)
SortingReader	desc(String fieldName)
DataReader	getNestedReader() Returns the DataReader held inside this one or null if there isn't one.
DataReader	getNestedReader0()
RecordComparator	getOrder()
boolean	isCacheFieldIndexes()
void	open() Makes this endpoint ready for reading or writing.
protected Record	readImpl() Overridden by subclasses to read the next record from this DataReader.
SortingReader	setCacheFieldIndexes(boolean cacheFieldIndexes)

Methods inherited from class com.northconcepts.datapipeline.core.ProxyReader

addExceptionProperties, available, interceptRecord, map, map, setNestedDataReader, setNestedDataReader

Methods inherited from class com.northconcepts.datapipeline.core.DataReader

addLineage, getBufferSize, getNestedEndpoint, getRootEndpoint, getRootReader, isExhausted, isLineageSupported, isSaveLineage, peek, pop, push, read, setSaveLineage, skip

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object

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

Constructor Detail

SortingReader

public SortingReader(DataReader reader,
                     long bufferSize)

Parameters:

reader -

bufferSize - memory buffer in bytes

SortingReader

public SortingReader(DataReader reader)

Method Detail

getNestedReader

public DataReader getNestedReader()

Description copied from class: DataReader

Returns the DataReader held inside this one or null if there isn't one.

Overrides:

getNestedReader in class ProxyReader

getNestedReader0

public DataReader getNestedReader0()

isCacheFieldIndexes

public boolean isCacheFieldIndexes()

setCacheFieldIndexes

public SortingReader setCacheFieldIndexes(boolean cacheFieldIndexes)

getOrder

public RecordComparator getOrder()

add

public SortingReader add(String fieldName)

add

public SortingReader add(String fieldName,
                         boolean ascending)

asc

public SortingReader asc(String fieldName)

desc

public SortingReader desc(String fieldName)

add

public SortingReader add(String fieldName,
                         boolean ascending,
                         Collator collator)

open

public void open()

Description copied from class: DataEndpoint

Makes this endpoint ready for reading or writing.

Overrides:

open in class ProxyReader

close

public void close()
           throws DataException

Description copied from class: DataEndpoint

Indicates that this endpoint has finished reading or writing.

Overrides:

close in class ProxyReader

Throws:

DataException

readImpl

protected Record readImpl()
                   throws Throwable

Description copied from class: DataReader

Overridden by subclasses to read the next record from this 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.

Overrides:

readImpl in class ProxyReader

Throws:

Throwable

copy

public static void copy(DataReader source,
                        DataWriter sink)
                 throws Throwable

Throws:

Throwable