rivet-cli 0.13.0

Rivet: PostgreSQL/MySQL/SQL Server → Parquet/CSV (local, S3, GCS, Azure). Crate name rivet-cli; binary rivet.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Incremental cursor configuration (Epic D — cursor policy).
//!
//! `cursor_column` remains the primary progression column. Optional `cursor_fallback_column`
//! plus [`IncrementalCursorMode::Coalesce`] uses `COALESCE(primary, fallback)` for the
//! incremental predicate and stored cursor value (single scalar string in state).

use schemars::JsonSchema;
use serde::{Deserialize, Serialize};

/// How the primary (and optional fallback) column(s) participate in incremental extraction.
#[derive(Debug, Deserialize, Serialize, JsonSchema, Clone, Copy, PartialEq, Eq, Default)]
#[serde(rename_all = "snake_case")]
pub enum IncrementalCursorMode {
    /// `WHERE primary > last ORDER BY primary` — optional fallback column is ignored for execution.
    #[default]
    SingleColumn,
    /// `WHERE COALESCE(primary, fallback) > last` with a synthetic result column for cursor extraction.
    Coalesce,
}