Skip to content
This repository has been archived by the owner on Jun 6, 2024. It is now read-only.

Commit

Permalink
added stages configuration
Browse files Browse the repository at this point in the history
  • Loading branch information
Makoto-Tomokiyo committed Apr 30, 2024
1 parent fa45e8d commit 2bac057
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 2 deletions.
4 changes: 4 additions & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -33,3 +33,7 @@ chrono = {version = "0.4.38", features = ["serde"]}

[build-dependencies]
tonic-build = "0.11"

[features]
stages = []
intraoperator = ["stages"]
9 changes: 7 additions & 2 deletions src/query_graph.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,8 +46,13 @@ pub struct QueryGraph {

impl QueryGraph {
pub async fn new(query_id: u64, plan: Arc<dyn ExecutionPlan>) -> Self {
let mut builder = GraphBuilder::new();
let stages = builder.build(plan.clone());

// Build stages.
// To run this configuration, use 'cargo build --features stages'.
#[cfg(feature="stages")] {
let mut builder = GraphBuilder::new();
let stages = builder.build(plan.clone());
}

let tid_counter = AtomicU64::new(0);
let id = tid_counter.fetch_add(1, Ordering::SeqCst);
Expand Down

0 comments on commit 2bac057

Please sign in to comment.