All Classes and Interfaces
Class
Description
Filters JSONObjects based on multiple criteria, requiring all conditions to be met.
Encapsulates a database operation such as an insert or update within a
managed transaction.
Bulk insert or update a stream of records in a single transaction.
Decodes JBIN encoded streams into JSON.
Used for encoding data into the JBIN format.
A Source implementation that provides stream access to a byte array
A Target that writes the data to a memory buffer.
A Source implementation that loads resources from the classpath.
Extends Iterator and AutoCloseable for safe iteration and resource
management.
A transformer that converts string values in JSON objects to their appropriate data types.
Compares objects of different types, supporting nulls, numbers, and comparables.
Filters data by comparing a specified key-value pair using a flexible coercive comparator.
Finds unique (complement) JSON records that only appear in the first stream.
Filters out JSONObjects based on string containment comparison.
Represents a runtime exception specific to the Convirgance API, providing
focused and contained error messages for debugging.
Provides streaming support for reading RFC 4180 compliant CSV (Comma-Separated Values) files
and converting them to JSONObjects.
Writes data in RFC 4180 compliant CSV format.
Transforms the Date values of a JSONObject into long-formatted epoch timestamps.
Transforms Date values in a JSONObject into ISO 8601 string format.
Primary interface for querying SQL-based database management
systems (DBMS) like MySQL, PostgreSQL, SQL Server, Oracle, and others.
Provides support for reading character delimited files as a stream of data.
Support for writing delimited file formats like tab delimited and pipe delimited
formats.
Transforms long numbers representing a millisecond timestamp into Date objects.
Used when filtering data that should be equal to some criteria.
Provides access to an underlying file resource
Provides write access to an underlying file resource.
Defines a filter that evaluates each record in a collection against a
condition.
Used to check if a JSONObjects key has a value greater than the provided minimum value.
Filters JSONObjects where the value of a specified key is greater than or
equal to a comparison value.
Guarantees that a single record will be produced for each record consumed.
Interface for reading file formats as an Iterable stream of data
Extends Iterable to provide a CloseableIterator that can be terminated before
all data is read without leaking resources.
A Source implementation that wraps an InputStream and provides one-time access to it.
A transformer that inserts or updates a key-value pair in a JSON object.
Finds common JSON records that appear in multiple sorted
Iterable streams.Transforms ISO 8601 formatted strings into Date objects.
Provides support for reading binary encoded JSON data in the JBIN format.
Provides support for writing binary encoded JSON data in the JBIN format.
A List implementation that supports JSON array data
Provides support for reading JSON formatted objects as a stream of data.
A JSON object implementation that represents a collection of key-value pairs.
Provides support for writing a stream of data as JSON formatted objects.
Supports parsing a Stream containing JSON, processing values as their relevant data type.
Serializes data into JSON format and writes it to an output stream
Interface for encoding and decoding key-value data, enabling custom serialization for keys in binary data streams.
Use when you need to map string keys to unique integer IDs for stream processing.
KeyTableEncoder provides a fixed-size mapping between string keys and unique integer indexes.
Filters JSONObjects where the value of the specified key is less than the provided comparison value.
Filters JSONObjects where the value of the specified key is less than or equal to the provided comparison value.
Filter out JSONObjects by using a SQL-esque Like operator.
Filters JSONObjects that do not meet the condition of an existing filter.
Used to filter JSONObjects that meet any of a given criteria.
Interface for writing file formats from an Iterable stream of data
A cursor for manually writing data to a given
Output format.A Target implementation that wraps an OutputStream and provides one-time access to it
Provides support for reading pipe-delimited files as a stream of data.
Provides support for writing pipe-delimited files as a stream of data.
A single SQL query for select, insert, and update operations.
Base class for all markup of the SQL query.
Represents the location of a parameter in the SQL query.
Represents a string identified in the SQL query.
Encapsulates a
Query to ensure parameters are properly bound
before execution.Transforms pre-sorted JSON data by grouping records that share common field values.
Abstracts away access to an on-demand InputStream over a given resource.
The StringEncoder class maps strings to unique integer indexes, supporting up to 256 strings.
Provides support for reading tab-delimited (tsv) files as a stream of data.
Provides support for writing tab-delimited (tsv) files as a stream of data.
Abstracts away access to an on-demand OutputStream over a given resource.
Represents a set of database operations, such as queries or updates, executed
as a single transaction.
An interface for applying lazy transformations to JSON objects during iteration.
Combines multiple streams of data into a single stream.
Transforms unsorted JSON data by grouping records that share common field values.
Retrieve data from a resource identified by a URL.
Value Generators analyze the current record and produce a value that will
be inserted or updated in the record.