Package com.northconcepts.datapipeline.core

Interface Summary

Session

Class Summary

AbstractReader	Abstract super-class, with some common logic, for reading records.
AbstractWriter	Abstract super-class, with some common logic, for writing records.
AsyncReader	A proxy that reads data asynchronously using a separate thread.
BinaryWriter	Abstract super-class for writing records to a binary stream.
CompositeValue
DataEndpoint	Abstract super-class for reading and writing records.
DataEndpointGroup	Helper class--makes it easy to work with multiple readers and writers as a single unit.
DataReader	Abstract super-class for reading records.
DataWriter	Abstract super-class for writing records.
DebugReader	A proxy that prints records passing through to a stream in a human-readable format
Field
FieldComparator
FieldDeclarations
FieldList
Functions
LinedTextWriter	Abstract super-class for writing records to a text stream.
Message
Messages
MultiWriter	Writes records to multiple DataWriter.
NullWriter	Discards records.
Parser
ParsingReader
ProxyReader	Abstract super-class for obtaining records from another DataReader, possibly transforming them along the way.
ProxyWriter	Abstract super-class for writing records to another DataWriter, possibly transforming them along the way.
Record
RecordComparator
RecordList
RemoveDuplicatesReader	A proxy that removes duplicate records.
SequenceReader
Session.SessionImpl
SortingReader	A proxy that sorts records.
StreamWriter	Writes records to a stream in a human-readable format.
TextReader	Abstract super-class for obtaining records from a text stream.
TextWriter

Enum Summary

DataEndpoint.State
FieldType
Message.Level
Record.State

Exception Summary

DataException

Indicates an error has occurred during the course of execution.