fmt

Signed-off-by: Bugen Zhao <i@bugenzhao.com>
risingwavelabs · Feb 20, 2025 · d0ba5a0 · d0ba5a0
1 parent 87c9597
commit d0ba5a0
Show file tree

Hide file tree

Showing 10 changed files with 0 additions and 23 deletions.
diff --git a/src/connector/src/sink/deltalake.rs b/src/connector/src/sink/deltalake.rs
@@ -616,12 +616,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".into(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".into(),
-
             },
         ]);
 

diff --git a/src/connector/src/sink/kafka.rs b/src/connector/src/sink/kafka.rs
@@ -752,12 +752,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".into(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "v2".into(),
-
             },
         ]);
 

diff --git a/src/connector/src/sink/postgres.rs b/src/connector/src/sink/postgres.rs
@@ -602,12 +602,10 @@ mod tests {
             Field {
                 data_type: DataType::Int32,
                 name: "a".to_owned(),
-
             },
             Field {
                 data_type: DataType::Int32,
                 name: "b".to_owned(),
-
             },
         ]);
         let table_name = "test_table";
@@ -624,12 +622,10 @@ mod tests {
             Field {
                 data_type: DataType::Int32,
                 name: "a".to_owned(),
-
             },
             Field {
                 data_type: DataType::Int32,
                 name: "b".to_owned(),
-
             },
         ]);
         let table_name = "test_table";

diff --git a/src/connector/src/sink/redis.rs b/src/connector/src/sink/redis.rs
@@ -508,12 +508,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".to_owned(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".to_owned(),
-
             },
         ]);
 
@@ -579,12 +577,10 @@ mod test {
             Field {
                 data_type: DataType::Int32,
                 name: "id".to_owned(),
-
             },
             Field {
                 data_type: DataType::Varchar,
                 name: "name".to_owned(),
-
             },
         ]);
 

diff --git a/src/frontend/src/optimizer/plan_node/generic/agg.rs b/src/frontend/src/optimizer/plan_node/generic/agg.rs
@@ -676,7 +676,6 @@ impl<PlanRef: stream::StreamPlanRef> Agg<PlanRef> {
                     table_builder.add_column(&Field {
                         data_type: DataType::Int64,
                         name: format!("count_for_agg_call_{}", call_index),
-
                     });
                 }
                 table_builder

diff --git a/src/frontend/src/optimizer/plan_node/generic/now.rs b/src/frontend/src/optimizer/plan_node/generic/now.rs
@@ -58,7 +58,6 @@ impl GenericPlanNode for Now {
             } else {
                 "ts"
             }),
-
         }])
     }
 

diff --git a/src/frontend/src/optimizer/plan_node/generic/source.rs b/src/frontend/src/optimizer/plan_node/generic/source.rs
@@ -163,12 +163,10 @@ impl Source {
         let key = Field {
             data_type: DataType::Varchar,
             name: "partition_id".to_owned(),
-
         };
         let value = Field {
             data_type: DataType::Jsonb,
             name: "offset_info".to_owned(),
-
         };
 
         let ordered_col_idx = builder.add_column(&key);

diff --git a/src/frontend/src/optimizer/plan_node/logical_source.rs b/src/frontend/src/optimizer/plan_node/logical_source.rs
@@ -188,7 +188,6 @@ impl LogicalSource {
                         &Field {
                             name: "filename".to_owned(),
                             data_type: DataType::Varchar,
-
                         },
                         0,
                     ),
@@ -199,7 +198,6 @@ impl LogicalSource {
                         &Field {
                             name: "last_edit_time".to_owned(),
                             data_type: DataType::Timestamptz,
-
                         },
                         1,
                     ),
@@ -210,7 +208,6 @@ impl LogicalSource {
                         &Field {
                             name: "file_size".to_owned(),
                             data_type: DataType::Int64,
-
                         },
                         0,
                     ),

diff --git a/src/frontend/src/optimizer/plan_node/stream_source_scan.rs b/src/frontend/src/optimizer/plan_node/stream_source_scan.rs
@@ -85,12 +85,10 @@ impl StreamSourceScan {
         let key = Field {
             data_type: DataType::Varchar,
             name: "partition_id".to_owned(),
-
         };
         let value = Field {
             data_type: DataType::Jsonb,
             name: "backfill_progress".to_owned(),
-
         };
 
         let ordered_col_idx = builder.add_column(&key);

diff --git a/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs b/src/frontend/src/optimizer/plan_node/stream_watermark_filter.rs
@@ -122,12 +122,10 @@ pub fn infer_internal_table_catalog(watermark_type: DataType) -> TableCatalog {
     let key = Field {
         data_type: DataType::Int16,
         name: "vnode".to_owned(),
-
     };
     let value = Field {
         data_type: watermark_type,
         name: "offset".to_owned(),
-
     };
 
     let ordered_col_idx = builder.add_column(&key);
-Original file line number
+Diff line change
@@ Expand Up / @@ -58,7 +58,6 @@ impl GenericPlanNode for Now { @@
                 } else {
                     "ts"
                 }),
             }])
         }
@@ Expand Down @@