feat: add feature disable_merge_sinker

it will disable merge multi sink with same table into one
ArroyoSystems · Sep 6, 2024 · 6ca31c4 · 6ca31c4
1 parent dee4f65
commit 6ca31c4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/crates/arroyo-planner/Cargo.toml b/crates/arroyo-planner/Cargo.toml
@@ -3,6 +3,8 @@ name = "arroyo-df"
 version = "0.12.0-dev"
 edition = "2021"
 
+[features]
+disable_merge_sinker = []
 
 [dependencies]
 arroyo-types = { path = "../arroyo-types" }

diff --git a/crates/arroyo-planner/src/extension/sink.rs b/crates/arroyo-planner/src/extension/sink.rs
@@ -141,6 +141,9 @@ impl UserDefinedLogicalNodeCore for SinkExtension {
 
 impl ArroyoExtension for SinkExtension {
     fn node_name(&self) -> Option<NamedNode> {
+        if cfg!(feature = "disable_merge_sinker") {
+            return None;
+        }
         match &self.table {
             Table::PreviewSink { .. } => None,
             _ => Some(NamedNode::Sink(self.name.clone())),