diff --git a/datafusion/functions-table/src/generate_series.rs b/datafusion/functions-table/src/generate_series.rs index 84b3be4e4603..ced43ea8f00c 100644 --- a/datafusion/functions-table/src/generate_series.rs +++ b/datafusion/functions-table/src/generate_series.rs @@ -44,7 +44,7 @@ struct GenerateSeriesTable { #[derive(Debug, Clone)] struct GenerateSeriesState { schema: SchemaRef, - _start: i64, // Kept for display + start: i64, // Kept for display end: i64, batch_size: usize, @@ -58,7 +58,7 @@ impl fmt::Display for GenerateSeriesState { write!( f, "generate_series: start={}, end={}, batch_size={}", - self._start, self.end, self.batch_size + self.start, self.end, self.batch_size ) } } @@ -116,7 +116,7 @@ impl TableProvider for GenerateSeriesTable { self.schema.clone(), vec![Arc::new(RwLock::new(GenerateSeriesState { schema: self.schema.clone(), - _start: start, + start, end, current: start, batch_size, @@ -129,7 +129,7 @@ impl TableProvider for GenerateSeriesTable { self.schema.clone(), vec![Arc::new(RwLock::new(GenerateSeriesState { schema: self.schema.clone(), - _start: 0, + start: 0, end: 0, current: 1, batch_size, diff --git a/datafusion/physical-plan/src/memory.rs b/datafusion/physical-plan/src/memory.rs index b7f983b9adad..bf6294f5a55b 100644 --- a/datafusion/physical-plan/src/memory.rs +++ b/datafusion/physical-plan/src/memory.rs @@ -380,7 +380,7 @@ pub struct LazyMemoryExec { schema: SchemaRef, /// Functions to generate batches for each partition batch_generators: Vec>>, - /// Total number of rows to generate for statistics + /// Plan properties cache storing equivalence properties, partitioning, and execution mode cache: PlanProperties, }