Trait DatafusionDatagenExt 

pub trait DatafusionDatagenExt {
    // Required methods
    fn into_df_stream(
        self,
        batch_size: RowCount,
        num_batches: BatchCount,
    ) -> SendableRecordBatchStream;
    fn into_df_stream_bytes(
        self,
        batch_size: ByteCount,
        num_batches: BatchCount,
        rounding_behavior: RoundingBehavior,
    ) -> Result<SendableRecordBatchStream, Error>;
    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_stream_bytes( self, batch_size: ByteCount, num_batches: BatchCount, rounding_behavior: RoundingBehavior, ) -> Result<SendableRecordBatchStream, Error>

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

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl DatafusionDatagenExt for BatchGeneratorBuilder

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

fn into_df_stream_bytes( self, batch_size: ByteCount, num_batches: BatchCount, rounding_behavior: RoundingBehavior, ) -> Result<SendableRecordBatchStream, Error>

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

Implementors