Trait DatafusionDatagenExt

pub trait DatafusionDatagenExt {
    // Required methods
    fn into_df_stream(
        self,
        batch_size: RowCount,
        num_batches: BatchCount,
    ) -> SendableRecordBatchStream;
    fn into_df_exec(
        self,
        batch_size: RowCount,
        num_batches: BatchCount,
    ) -> Arc<dyn ExecutionPlan>;
}

Required Methods

fn into_df_stream( self, batch_size: RowCount, num_batches: BatchCount, ) -> SendableRecordBatchStream

fn into_df_exec( self, batch_size: RowCount, num_batches: BatchCount, ) -> Arc<dyn ExecutionPlan>

Implementations on Foreign Types

impl DatafusionDatagenExt for BatchGeneratorBuilder

fn into_df_stream( self, batch_size: RowCount, num_batches: BatchCount, ) -> SendableRecordBatchStream

fn into_df_exec( self, batch_size: RowCount, num_batches: BatchCount, ) -> Arc<dyn ExecutionPlan>

Implementors