Fix Lint

databendlabs · Oct 20, 2021 · d3f9b47 · d3f9b47
1 parent 7b1d88e
commit d3f9b47
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/query/src/datasources/table/fuse/table_do_read.rs b/query/src/datasources/table/fuse/table_do_read.rs
@@ -56,7 +56,6 @@ impl FuseTable {
         // TODO we need a configuration to specify the unit of dequeue operation
         let bite_size = 1;
         let iter = {
-            let ctx = ctx.clone();
             std::iter::from_fn(move || match ctx.clone().try_get_partitions(bite_size) {
                 Err(_) => None,
                 Ok(parts) if parts.is_empty() => None,

diff --git a/query/src/datasources/table/memory/memory_table_stream.rs b/query/src/datasources/table/memory/memory_table_stream.rs
@@ -38,7 +38,7 @@ pub struct MemoryTableStream {
 impl MemoryTableStream {
     pub fn try_create(ctx: DatabendQueryContextRef, blocks: Vec<DataBlock>) -> Result<Self> {
         Ok(Self {
-            ctx: ctx.clone(),
+            ctx,
             block_index: 0,
             block_ranges: vec![],
             blocks,

diff --git a/query/src/datasources/table_func/numbers_stream.rs b/query/src/datasources/table_func/numbers_stream.rs
@@ -39,7 +39,7 @@ pub struct NumbersStream {
 impl NumbersStream {
     pub fn try_create(ctx: DatabendQueryContextRef, schema: DataSchemaRef) -> Result<Self> {
         Ok(Self {
-            ctx: ctx.clone(),
+            ctx,
             schema,
             block_index: 0,
             blocks: vec![],