Trait chopper_lib::chopper::chopper::DataSink

pub trait DataSink {
    fn flush(&mut self) -> CliResult<()>;
    fn boxed(self) -> Box<dyn DataSink>;

    fn write_row(&mut self, row: Row) -> CliResult<Option<Row>> { ... }
    fn write_row_to_pin(
        &mut self, 
        _pin_id: PinId, 
        row: Row
    ) -> CliResult<Option<Row>> { ... }
    fn finish(self: Box<Self>) -> CliResult<()> { ... }
}

Required methods

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

Loading content...

Provided methods

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn finish(self: Box<Self>) -> CliResult<()>

Loading content...

Implementors

impl DataSink for MergeJoin

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

impl DataSink for ColumnFilterDelete

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

impl DataSink for RowFilterEqualValue

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

impl DataSink for RowFilterGreaterValue

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

impl DataSink for CSVSink

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

impl DataSink for DCSink

fn write_row(&mut self, row: Row) -> CliResult<Option<Row>>

fn write_row_to_pin(
    &mut self,
    _pin_id: PinId,
    row: Row
) -> CliResult<Option<Row>>

fn flush(&mut self) -> CliResult<()>

fn boxed(self) -> Box<dyn DataSink>

Loading content...