Skip to content

Commit 6005542

Browse files
committed
refactor(cubesql): Turn extend_values to generic, get params by value
1 parent e1b84fc commit 6005542

File tree

1 file changed

+4
-4
lines changed
  • rust/cubesql/cubesql/src/compile/engine/df

1 file changed

+4
-4
lines changed

rust/cubesql/cubesql/src/compile/engine/df/wrapper.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -145,8 +145,8 @@ impl SqlQuery {
145145
index
146146
}
147147

148-
pub fn extend_values(&mut self, values: &Vec<Option<String>>) {
149-
self.values.extend(values.iter().cloned());
148+
pub fn extend_values(&mut self, values: impl IntoIterator<Item = Option<String>>) {
149+
self.values.extend(values.into_iter());
150150
}
151151

152152
pub fn replace_sql(&mut self, sql: String) {
@@ -969,7 +969,7 @@ impl CubeScanWrapperNode {
969969
.await?;
970970

971971
let (sql_string, new_values) = subquery_sql.unpack();
972-
sql.extend_values(&new_values);
972+
sql.extend_values(new_values);
973973
// TODO why only field 0 is a key?
974974
let field = subquery.schema().field(0);
975975
subqueries_sql.insert(field.qualified_name(), sql_string);
@@ -1044,7 +1044,7 @@ impl CubeScanWrapperNode {
10441044
)
10451045
.await?;
10461046
let (subq_sql_string, new_values) = subq_sql.sql.unpack();
1047-
sql.extend_values(&new_values);
1047+
sql.extend_values(new_values);
10481048
let subq_alias = subq_sql.from_alias;
10491049
// Expect that subq_sql.column_remapping already incorporates subq_alias/
10501050
// TODO does it?

0 commit comments

Comments
 (0)