Struct StarRocksCatalogProvider 

pub struct StarRocksCatalogProvider {
    pub fe_http_url: String,
    pub flight_sql_url: Option<String>,
    pub mode: IngestionMode,
    /* private fields */
}

Fields

fe_http_url: String

flight_sql_url: Option<String>

mode: IngestionMode

Implementations

impl StarRocksCatalogProvider

pub fn new( fe_http_url: String, flight_sql_url: Option<String>, mode: IngestionMode, ) -> Self

Trait Implementations

impl CatalogProvider for StarRocksCatalogProvider

type Error = StarRocksError

Backend-specific error type (snafu enum).

fn get_table_spec<'life0, 'life1, 'async_trait>( &'life0 self, _table: &'life1 TableIdent, ) -> Pin<Box<dyn Future<Output = Result<TableSpec, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load a table’s current spec (schema, partition spec, properties, current snapshot pointer). MUST be idempotent and safe to call concurrently.

fn write_batch<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 TableIdent, batch: RecordBatch, ) -> Pin<Box<dyn Future<Output = Result<WriteReceipt, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Write a batch of Arrow data to the backend’s storage layer. MUST NOT visibly commit until commit is called — for open table formats, this produces staged data files; for StarRocks Stream Load and Flight SQL, this is part of the commit itself.

fn commit<'life0, 'life1, 'async_trait>( &'life0 self, _table: &'life1 TableIdent, _receipts: Vec<WriteReceipt>, ) -> Pin<Box<dyn Future<Output = Result<CommitOutcome, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Commit previously written batches. For CAS-based backends (Iceberg, Delta, Paimon), MUST be implemented with a retry loop. For non-transactional backends (StarRocks), MAY be a no-op.

fn get_security_context<'life0, 'life1, 'async_trait>( &'life0 self, _table: &'life1 TableIdent, ) -> Pin<Box<dyn Future<Output = Result<SecurityContext, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the security context (credentials, encryption metadata) for the table. Implementations MUST fetch short-lived credentials and MUST NOT cache beyond the credential’s expiry.