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>;
}