Skip to content

Commit 57fa9de

Browse files
update query
1 parent bf51964 commit 57fa9de

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

src/parseable/streams.rs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1110,12 +1110,10 @@ async fn calculate_single_field_stats(
11101110
field_name: &str,
11111111
) -> Option<FieldStat> {
11121112
let count = query_single_i64(
1113-
&ctx,
1114-
&format!(
1115-
"select count(\"{field_name}\") as count from \"{stream_name}\" where \"{field_name}\" is not null"
1116-
),
1117-
)
1118-
.await?;
1113+
&ctx,
1114+
&format!("select count(\"{field_name}\") as count from \"{stream_name}\""),
1115+
)
1116+
.await?;
11191117
if count == 0 {
11201118
return None;
11211119
}

0 commit comments

Comments
 (0)