Module com.darkcollective.relix.processor

Package com.darkcollective.relix.processor.internal

package com.darkcollective.relix.processor.internal

The engine-side machinery behind com.darkcollective.relix.processor: not exported by the published artifact. What follows describes the package as a whole, as it stood before the split. Core query-execution types for the relix processor.

This package contains the central runtime data structures:

• Row — a single tuple produced during query execution; an ordered sequence of Values described by a Schema.
• ArrayRow — the standard positional implementation of Row, backed by a fixed-size Value[] array.
• DataSourceConnector — the functional interface that bridges external data sources (JDBC, HTTP) to the Row stream model.
• ExecutionContext — the shared context threaded through all operators: symbol table, per-node schema annotations, and the data-source connector.

Scalar values are in the sub-package com.darkcollective.relix.value. Expression and predicate evaluators are in com.darkcollective.relix.processor.eval. Execution operators that transform Stream<Row> pipelines are in com.darkcollective.relix.processor.exec.

Related Packages

Package	Description
com.darkcollective.relix.processor	Row: one row of a result, a tuple of Values read by position or by column name.
com.darkcollective.relix.processor.connector	The connector provider interface, and connector plugin provisioning.
com.darkcollective.relix.processor.eval	Scalar expression and predicate evaluation for query execution.
com.darkcollective.relix.processor.exec	Execution operators for the relix processor.
com.darkcollective.relix.processor.generator	Generator relations — leaf relations whose rows are produced by engine code rather than read from a file or database.
com.darkcollective.relix.processor.provenance	A relation annotated over a semiring, as Relation.provenance returns it.

Class	Description
ArrayRow	A positional Row implementation backed by a fixed-size array of Values.
DataSourceConnector	Plug-in boundary between the query executor and an external data source.
DocumentRow	A Row backed by a nested StructValue document — the row shape produced by an open (schema-on-read) source such as the JSON file connector.
ExecutionContext	Shared execution state threaded through all operators during query evaluation.
PhysicalPlanConsumer	Callback that receives one query's planned PhysicalNode, without executing it.
PlanConsumer	Callback that receives one query's physical plan, rendered as text.
ProvenanceConsumer<K>	Callback that receives one query's result as an annotated K-relation.
QueryExecutor	Top-level orchestrator that drives query execution against a validated SemanticModel.
QueryResult	The fully-materialised result of executing a single query statement.
RowStreamConsumer	Callback that receives one query's result as a lazy Stream of rows.