Skip to main content

sink_is_exactly_once

risingwave_connector::sink

Function sink_is_exactly_once 

Source 
pub fn sink_is_exactly_once(
    properties: &BTreeMap<String, String>,
) -> Result<bool>
Expand description

Return whether the configured sink uses exactly-once commit state.

Connector dispatch is centralized here, while each Sink implementation owns the interpretation and default of its properties.