Session is the base type for objects that can contain temporary, non-persistent data in Data Pipeline.
A general interface for nodes that allow values to be added to itself.
Abstract super-class, with some common logic, for reading records.
Abstract super-class, with some common logic, for writing records.
ArrayValue holds an ordered collection (also known as a sequence) of persistent data.
AsyncMultiReader reads from one or more source DataReaders asynchronously using a separate thread for each one.
A proxy that reads data asynchronously using a separate thread.
A proxy that writes data asynchronously using a separate thread.
Abstract super-class for writing records to a binary stream.
Abstract super-class for reading and writing records.
Helper class--makes it easy to work with multiple readers and writers as a single unit.
Abstract super-class for classes that work with data and require a consistent error handling mechanism.
Abstract super-class for reading records.
Abstract super-class for writing records.
A proxy that prints records passing through to a stream in a human-readable format
Field holds persistent key-value data as part of a record.
An abstract representation for the location of a field within a record.
Functions is the entry point for adding new method aliases to the dynamic expression language.
A proxy that can skip a number of upstream records, limit the number of records sent downstream, or both.
Abstract super-class for writing records to a text stream.
Thread-local container for messages and exceptions originating in asynchronous operations.
Writes records to multiple
Writes each record to all writers.
Divides records evenly between all writers by cycling through the list and writing each record to a single writer in turn.
Node is the base class for all persistent data in Data Pipeline.
Abstract super-class for obtaining records from a text stream using a parser.
Abstract super-class for obtaining records from another
Abstract super-class for writing records to another
Record holds persistent data in key-value fields as it flows through the pipeline.
A proxy that removes duplicate records.
Combines one or more DataReaders into a single stream by reading from each until empty then moving to the next.
A proxy that sorts records.
Writes records to a stream in a human-readable format.
A proxy reader that also writes every record passing through it to a DataWriter.
Abstract super-class for obtaining records from a text stream.
ValueNode is the base class for all persistent values held in fields and arrays.
FieldType lists of all field data types used in records.
DuplicateNodeAction lists all actions that can be taken automatically when a target field already exists during a record copy or lookup.
NodeType lists all concrete data node types used in Data Pipeline.
Indicates an error has occurred during the course of execution.