com.northconcepts.datapipeline.core
Class SortingReader

java.lang.Object
  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.DataEndpoint

BUFFER_SIZE, log

Constructor Summary

SortingReader(DataReader reader)

SortingReader(DataReader reader, int bufferSize)

Method Summary

static void	copy(DataReader source, DataWriter sink)
RecordComparator	getOrder()
boolean	isCacheFieldIndexes()
void	open() Makes this endpoint ready for reading or writing.
SortingReader	setCacheFieldIndexes(boolean cacheFieldIndexes)

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

addExceptionProperties, available, close, getNestedReader, interceptRecord, readImpl, setNestedDataReader, setNestedDataReader

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

getBufferSize, getRootReader, peek, pop, push, read, skip

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

assertNotOpened, assertOpened, decrementRecordCount, exception, exception, exception, finalize, getDescription, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, getState, incrementRecordCount, isClosed, isOpen, isRecordCountBigInteger, resetRecordCount, setDescription, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SortingReader

public SortingReader(DataReader reader,
                     int bufferSize)

Parameters:

reader -

bufferSize - memory buffer in megabytes (1048576 bytes)

SortingReader

public SortingReader(DataReader reader)

Method Detail

isCacheFieldIndexes

public boolean isCacheFieldIndexes()

setCacheFieldIndexes

public SortingReader setCacheFieldIndexes(boolean cacheFieldIndexes)

getOrder

public RecordComparator getOrder()

open

public void open()

Description copied from class: DataEndpoint

Makes this endpoint ready for reading or writing.

Overrides:

open in class ProxyReader

copy

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

Throws:

Throwable