Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: make Selection Copy

pull/24376/head
Edd Robinson 2021-02-22 12:23:31 +00:00 committed by kodiakhq[bot]
parent aa09cd3579
commit 4caa1d732f
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
data_types/src/selection.rs
View File

@ -1,4 +1,4 @@
#[derive(Debug, Clone)] #[derive(Debug, Clone, Copy)]
/// A collection of columns to include in query results. /// A collection of columns to include in query results.
/// ///
/// The `All` variant denotes that the caller wishes to include all table /// The `All` variant denotes that the caller wishes to include all table

2
query/src/frontend/influxrpc.rs
View File

@ -522,7 +522,7 @@ impl InfluxRPCPlanner {
); );
let chunk_table_schema = chunk let chunk_table_schema = chunk
.table_schema(table_name, selection.clone()) .table_schema(table_name, selection)
.await .await
.map_err(|e| Box::new(e) as _) .map_err(|e| Box::new(e) as _)
.context(GettingTableSchema { .context(GettingTableSchema {

2
server/src/db/chunk.rs
View File

@ -246,7 +246,7 @@ impl PartitionChunk for DBChunk {
// Note Mutable buffer doesn't support predicate // Note Mutable buffer doesn't support predicate
// pushdown (other than pruning out the entire chunk // pushdown (other than pruning out the entire chunk
// via `might_pass_predicate) // via `might_pass_predicate)
let schema: Schema = self.table_schema(table_name, selection.clone()).await?; let schema: Schema = self.table_schema(table_name, selection).await?;
Ok(Box::pin(MutableBufferChunkStream::new( Ok(Box::pin(MutableBufferChunkStream::new(
Arc::clone(&chunk), Arc::clone(&chunk),