GoKawiilColumnar analytics and graph traversal in one fused pipeline.
Rayforce is a pure C17 zero-dependency embeddable engine where columnar analytics and graph traversals share a single operation DAG, pass through a multi-pass optimizer, and execute as fused morsel-driven bytecode. No malloc.
Quick Start
make # debug build (ASan + UBSan) make release # optimized build make test # run full test suite ./rayforce # start the Rayfall REPL
Rayfall REPL
Rayforce ships with Rayfall — a Lisp-like query language with a rich set of builtins. The REPL prompt is ‣ :
‣ (set t (table [Symbol Side Qty] (list [AAPL GOOG MSFT AAPL GOOG] [Buy Sell Buy Sell Buy] [100 200 150 300 250]))) ‣ (select {from:t by: Symbol Qty: (sum Qty)}) +--------+----------------------------+ | Symbol | Qty | | sym | i64 | +--------+----------------------------+ | AAPL | 400 | | GOOG | 450 | | MSFT | 150 | +-------------------------------------+ | 3 rows (3 shown) 2 columns (2 shown)| +-------------------------------------+ ‣ (pivot t 'Symbol 'Side 'Qty sum) +--------+-----+----------------------+ | Symbol | Buy | Sell | | sym | i64 | i64 | +--------+-----+----------------------+ | AAPL | 100 | 300 | | GOOG | 250 | 200 | | MSFT | 150 | 0 | +-------------------------------------+ | 3 rows (3 shown) 3 columns (3 shown)| +-------------------------------------+
C API
Headers: include/rayforce.h (types, memory, atoms, vectors, tables, symbols), src/ops/ops.h (DAG construction, opcodes, optimizer, executor, graph algorithms), src/mem/heap.h (allocator lifecycle).
#include <rayforce.h> #include "mem/heap.h" #include "ops/ops.h" int main ( void ) { ray_heap_init (); ray_sym_init (); /* Build a table */ int64_t regions [] = { 0 , 0 , 1 , 1 , 2 , 2 }; int64_t amounts [] = { 100 , 200 , 150 , 300 , 175 , 225 }; ray_t * reg = ray_vec_from_raw ( RAY_I64 , regions , 6 ); ray_t * amt = ray_vec_from_raw ( RAY_I64 , amounts , 6 ); ray_t * tbl = ray_table_new ( 2 ); tbl = ray_table_add_col ( tbl , ray_sym_intern ( "region" , 6 ), reg ); tbl = ray_table_add_col ( tbl , ray_sym_intern ( "amount" , 6 ), amt ); ray_release ( reg ); ray_release ( amt ); /* Group by region, sum amounts */ ray_graph_t * g = ray_graph_new ( tbl ); ray_op_t * keys [] = { ray_scan ( g , "region" ) }; uint16_t agg_ops [] = { OP_SUM }; ray_op_t * agg_ins [] = { ray_scan ( g , "amount" ) }; ray_op_t * grp = ray_group ( g , keys , 1 , agg_ops , agg_ins , 1 ); ray_t * result = ray_execute ( g , grp ); if ( result && ! RAY_IS_ERR ( result )) ray_release ( result ); ray_graph_free ( g ); ray_release ( tbl ); ray_sym_destroy (); ray_heap_destroy (); }
... continue reading