Expand description
Tabular effect features on Apache Arrow batches (Barn Effect algorithm).
Discretize columns, accumulate pairwise co-occurrence statistics, and produce per-row
{column}_effect attributions. See transform_record_batches
and transform_record_batches_chunked.
Structs§
- Activation
Config - Activation settings for both pipeline stages.
- Batch
Chunk - Feature columns from one batch — Arrow buffers shared via
ArrayRefwhere possible. - BinDepth
- Cancel
Token - Checked at the start of each batch iteration; safe to share across threads.
- Chunk
Table - Feature matrix columns (no target column), in schema order.
- ColGraph
- Maps column index in
ChunkTable-> original name; which indices are dropped from preprocessing. - Column
Preprocess - Ctrlc
Guard - Restores a no-op SIGINT handler when dropped.
- Effect
Context - Context passed to effect activations per row.
- Pair
Aggregator - Pair
Stats - Raw accumulated stats for one canonical unordered value-pair key in
vals_map. - Preprocess
Stream - Transform
Config - Full configuration for
crate::pipeline::transform_record_batches. - Transform
Limits - Optional fail-fast caps for large or wide transforms (all
None= no limits).
Enums§
- Batch
Column - Column storage for one batch pass.
- BinType
- Column
Vec - Effect
Activation - How combined column signal becomes an effect feature value.
- KgPair
Activation - How a KG edge weight is computed from accumulated pair counts.
- Outcome
Source - Outcome vector aligned with table rows.
- Outcomes
Ref - Borrowed outcomes for zero-copy aggregation when target is null-free Float32.
- Target
Column - Target column — shared Float32 buffer or owned fallback.
- Value
Key
Constants§
Functions§
- batch_
from_ map - Build a
RecordBatchfrom string-name → column map (mixed float / utf8). - concat_
same_ schema - round_
to_ significant_ figures - Match
preprocess_stream.round_to_significant_figures/ NumPy// 1on log scale. - split_
batch_ views - Zero-copy batch split: feature columns share Arrow buffers via
ArrayRef. - split_
batch_ xy - Extract feature table
X, targetY, and column metadata (materializes owned columns). - transform_
record_ batches - Chunked pipeline: preprocess passes, pair aggregation, then apply per batch.
- transform_
record_ batches_ chunked - Chunked pipeline: preprocess, pair aggregation, apply — returns one output batch per input batch.