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

fix: remove whitespace changes

pull/24376/head
Andrew Lamb 2021-06-08 14:46:55 -04:00
parent b23c4e5210
commit 666204d4a8
1 changed files with 73 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

146
query/src/provider.rs
View File

@ -321,38 +321,38 @@ impl<C: PartitionChunk + 'static> Deduplicater<C> {
/// The final UnionExec on top is to union the streams below. If there is only one stream, UnionExec
/// will not be added into the plan.
/// ```text
/// ┌─────────────────┐
/// │ UnionExec │
/// │ │
/// └─────────────────┘
/// ▲
/// │
/// ┌──────────────────────┴───────────┬─────────────────────┐
/// │ │ │
/// │ │ │
/// ┌─────────────────┐
/// │ UnionExec │
/// │ │
/// └─────────────────┘
/// ▲
/// │
/// ┌──────────────────────┴───────────┬─────────────────────┐
/// │ │ │
/// │ │ │
/// ┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
/// │ DeduplicateExec │ │ DeduplicateExec │ │IOxReadFilterNode│
/// └─────────────────┘ └─────────────────┘ │ (Chunk 4) │
/// ▲ ▲ └─────────────────┘
/// │ │
/// ┌───────────────────────┐ │
/// │SortPreservingMergeExec│ │
/// └───────────────────────┘ │
/// │ │
/// ┌───────────────────────┐ │
/// │SortPreservingMergeExec│ │
/// └───────────────────────┘ │
/// ▲ |
/// │ |
/// ┌───────────┴───────────┐ │
/// │ │ │
/// ┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
/// │ SortExec │ │ SortExec │ │ SortExec │
/// │ (optional) │ │ (optional) │ │ (optional) │
/// └─────────────────┘ └─────────────────┘ └─────────────────┘
/// ▲ ▲ ▲
/// │ │ │
/// │ │ │
/// ┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
/// │IOxReadFilterNode│ │IOxReadFilterNode│ │IOxReadFilterNode│
/// │ (Chunk 1) │ │ (Chunk 2) │ │ (Chunk 3) │
/// └─────────────────┘ └─────────────────┘ └─────────────────┘
/// ┌───────────┴───────────┐ │
/// │ │ │
/// ┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
/// │ SortExec │ │ SortExec │ │ SortExec │
/// │ (optional) │ │ (optional) │ │ (optional) │
/// └─────────────────┘ └─────────────────┘ └─────────────────┘
/// ▲ ▲ ▲
/// │ │ │
/// │ │ │
/// ┌─────────────────┐ ┌─────────────────┐ ┌─────────────────┐
/// │IOxReadFilterNode│ │IOxReadFilterNode│ │IOxReadFilterNode│
/// │ (Chunk 1) │ │ (Chunk 2) │ │ (Chunk 3) │
/// └─────────────────┘ └─────────────────┘ └─────────────────┘
///```
fn build_scan_plan(
@ -459,29 +459,29 @@ impl<C: PartitionChunk + 'static> Deduplicater<C> {
/// Return deduplicate plan for the given overlapped chunks
/// The plan will look like this
/// ```text
/// ┌─────────────────┐
/// │ DeduplicateExec │
/// └─────────────────┘
/// ▲
/// │
/// ┌───────────────────────┐
/// │SortPreservingMergeExec│
/// └───────────────────────┘
/// ▲
/// │
/// ┌───────────┴───────────┐
/// │ │
/// ┌─────────────────┐ ┌─────────────────┐
/// │ SortExec │ ... │ SortExec │
/// │ (optional) │ │ (optional) │
/// └─────────────────┘ └─────────────────┘
/// ▲ ▲
/// │ ... │
/// │ │
/// ┌─────────────────┐ ┌─────────────────┐
/// │IOxReadFilterNode│ │IOxReadFilterNode│
/// │ (Chunk 1) │ ... │ (Chunk n) │
/// └─────────────────┘ └─────────────────┘
/// ┌─────────────────┐
/// │ DeduplicateExec │
/// └─────────────────┘
/// ▲
/// │
/// ┌───────────────────────┐
/// │SortPreservingMergeExec│
/// └───────────────────────┘
/// ▲
/// │
/// ┌───────────┴───────────┐
/// │ │
/// ┌─────────────────┐ ┌─────────────────┐
/// │ SortExec │ ... │ SortExec │
/// │ (optional) │ │ (optional) │
/// └─────────────────┘ └─────────────────┘
/// ▲ ▲
/// │ ... │
/// │ │
/// ┌─────────────────┐ ┌─────────────────┐
/// │IOxReadFilterNode│ │IOxReadFilterNode│
/// │ (Chunk 1) │ ... │ (Chunk n) │
/// └─────────────────┘ └─────────────────┘
///```
fn build_deduplicate_plan_for_overlapped_chunks(
table_name: Arc<str>,
@ -502,22 +502,22 @@ impl<C: PartitionChunk + 'static> Deduplicater<C> {
/// Return deduplicate plan for a given chunk with duplicates
/// The plan will look like this
/// ```text
/// ┌─────────────────┐
/// │ DeduplicateExec │
/// └─────────────────┘
/// ▲
/// │
/// ┌─────────────────┐
/// │ SortExec │
/// │ (optional) │
/// └─────────────────┘
/// ▲
/// │
/// │
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
/// ┌─────────────────┐
/// │ DeduplicateExec │
/// └─────────────────┘
/// ▲
/// │
/// ┌─────────────────┐
/// │ SortExec │
/// │ (optional) │
/// └─────────────────┘
/// ▲
/// │
/// │
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
///```
fn build_deduplicate_plan_for_chunk_with_duplicates(
table_name: Arc<str>,
@ -537,10 +537,10 @@ impl<C: PartitionChunk + 'static> Deduplicater<C> {
/// Return the simplest IOx scan plan of a given chunk which is IOxReadFilterNode
/// ```text
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
///```
fn build_plan_for_non_duplicates_chunk(
table_name: Arc<str>,
@ -558,10 +558,10 @@ impl<C: PartitionChunk + 'static> Deduplicater<C> {
/// Return the simplest IOx scan plan for many chunks which is IOxReadFilterNode
/// ```text
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
/// ┌─────────────────┐
/// │IOxReadFilterNode│
/// │ (Chunk) │
/// └─────────────────┘
///```
fn build_plans_for_non_duplicates_chunk(
table_name: Arc<str>,