Expand description
Streaming input/output adapters for query execution.
NDJSON adapters evaluate each non-empty row independently while reusing the
caller’s crate::JetroEngine plan, VM, and tape execution caches.
Structs§
- Ndjson
Execution Report - Ndjson
Execution Stats - Ndjson
Options - Configuration for per-row NDJSON execution.
- Ndjson
PerRow Driver - Forward-only per-row NDJSON reader.
- Ndjson
RevDistinct Stats - Ndjson
Reverse File Driver - Reverse NDJSON line reader over a seekable file.
- Ndjson
Route Explain - Ndjson
Source Caps
Enums§
- Distinct
Front Filter Kind - Ndjson
Control - Ndjson
Fallback Reason - Ndjson
Null Output - Ndjson
Parallelism - Ndjson
Route Kind - Ndjson
RowFrame - Ndjson
Rows Plan Kind - Ndjson
Source - Input source for NDJSON APIs that can operate on either files or callers’ existing buffered readers.
- Ndjson
Source Mode - Ndjson
Writer Path Kind - Null
Payload - RowError
- Error with enough row context for users to find malformed input quickly.
Functions§
- collect_
ndjson - collect_
ndjson_ file - collect_
ndjson_ file_ with_ options - collect_
ndjson_ matches - collect_
ndjson_ matches_ file - collect_
ndjson_ matches_ file_ with_ options - collect_
ndjson_ matches_ source - collect_
ndjson_ matches_ source_ with_ options - collect_
ndjson_ matches_ with_ options - collect_
ndjson_ rev - collect_
ndjson_ rev_ matches - collect_
ndjson_ rev_ matches_ with_ options - collect_
ndjson_ rev_ with_ options - collect_
ndjson_ source - collect_
ndjson_ source_ with_ options - collect_
ndjson_ with_ options - for_
each_ ndjson - for_
each_ ndjson_ rev - for_
each_ ndjson_ rev_ with_ options - for_
each_ ndjson_ source - for_
each_ ndjson_ source_ until - for_
each_ ndjson_ source_ until_ with_ options - for_
each_ ndjson_ source_ with_ options - for_
each_ ndjson_ until - for_
each_ ndjson_ until_ with_ options - for_
each_ ndjson_ with_ options - ndjson_
explain - ndjson_
rows_ plan_ kind - ndjson_
writer_ path_ kind - run_
ndjson - run_
ndjson_ file - run_
ndjson_ file_ limit - run_
ndjson_ file_ limit_ with_ options - run_
ndjson_ file_ limit_ with_ report - run_
ndjson_ file_ limit_ with_ report_ and_ options - run_
ndjson_ file_ with_ options - run_
ndjson_ file_ with_ report - run_
ndjson_ file_ with_ report_ and_ options - run_
ndjson_ limit - run_
ndjson_ limit_ with_ options - run_
ndjson_ limit_ with_ report - run_
ndjson_ limit_ with_ report_ and_ options - run_
ndjson_ matches - run_
ndjson_ matches_ file - run_
ndjson_ matches_ file_ with_ options - run_
ndjson_ matches_ file_ with_ report - run_
ndjson_ matches_ file_ with_ report_ and_ options - run_
ndjson_ matches_ source - run_
ndjson_ matches_ source_ with_ options - run_
ndjson_ matches_ source_ with_ report - run_
ndjson_ matches_ source_ with_ report_ and_ options - run_
ndjson_ matches_ with_ options - run_
ndjson_ matches_ with_ report - run_
ndjson_ matches_ with_ report_ and_ options - run_
ndjson_ rev - run_
ndjson_ rev_ distinct_ by - run_
ndjson_ rev_ distinct_ by_ with_ options - run_
ndjson_ rev_ distinct_ by_ with_ report - run_
ndjson_ rev_ distinct_ by_ with_ report_ and_ options - run_
ndjson_ rev_ distinct_ by_ with_ stats - run_
ndjson_ rev_ distinct_ by_ with_ stats_ and_ options - run_
ndjson_ rev_ limit - run_
ndjson_ rev_ limit_ with_ options - run_
ndjson_ rev_ matches - run_
ndjson_ rev_ matches_ with_ options - run_
ndjson_ rev_ matches_ with_ report - run_
ndjson_ rev_ matches_ with_ report_ and_ options - run_
ndjson_ rev_ with_ options - run_
ndjson_ source - run_
ndjson_ source_ limit - run_
ndjson_ source_ limit_ with_ options - run_
ndjson_ source_ limit_ with_ report - run_
ndjson_ source_ limit_ with_ report_ and_ options - run_
ndjson_ source_ with_ options - run_
ndjson_ source_ with_ report - run_
ndjson_ source_ with_ report_ and_ options - run_
ndjson_ with_ options - run_
ndjson_ with_ report - run_
ndjson_ with_ report_ and_ options