Trait Source

Source

pub trait Source: Send {
    // Required methods
    fn export(
        &mut self,
        query: &str,
        cursor_column: Option<&str>,
        cursor: Option<&CursorState>,
        tuning: &SourceTuning,
        sink: &mut dyn BatchSink,
    ) -> Result<()>;
    fn query_scalar(&mut self, sql: &str) -> Result<Option<String>>;
}