Struct StreamConfig 

pub struct StreamConfig {
    source: Arc<dyn StreamProvider>,
    order: Vec<Vec<SortExpr>>,
    constraints: Constraints,
}

The configuration for a StreamTable

Fields

source: Arc<dyn StreamProvider>

order: Vec<Vec<SortExpr>>

constraints: Constraints

Implementations

impl StreamConfig

pub fn new(source: Arc<dyn StreamProvider>) -> Self

Create a new StreamConfig from a StreamProvider

pub fn with_order(self, order: Vec<Vec<SortExpr>>) -> Self

Specify a sort order for the stream

pub fn with_constraints(self, constraints: Constraints) -> Self

Assign constraints

fn reader(&self) -> Result<Box<dyn RecordBatchReader>>

fn writer(&self) -> Result<Box<dyn RecordBatchWriter>>

Trait Implementations

impl Debug for StreamConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.