rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-06-03 22:00:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: import

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-06-01 21:13:27 +08:00
parent 10e26ba07e
commit 2a8eb59a14
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/query/src/dist_plan/dyn_filter_bridge.rs
View File

@@ -23,14 +23,8 @@ use datafusion::execution::TaskContext;
use datafusion_common::Result;
use datafusion_physical_expr::PhysicalExpr;
use datafusion_physical_expr::expressions::DynamicFilterPhysicalExpr;
#[cfg(test)]
use datafusion_physical_expr::expressions::{Column, lit};
use session::context::{QueryContext, QueryContextRef};
#[cfg(test)]
use session::query_id::QueryId;
use store_api::storage::RegionId;
#[cfg(test)]
use uuid::Uuid;
use crate::dist_plan::filter_id::build_remote_dyn_filter_id;
use crate::dist_plan::{FilterId, ProducerScopeId, QueryDynFilterRegistry, Subscriber};
@@ -195,6 +189,10 @@ pub(crate) fn query_context_with_initial_dyn_filter_regs(
#[cfg(test)]
mod tests {
use datafusion_physical_expr::expressions::{Column, lit};
use session::query_id::QueryId;
use uuid::Uuid;
use super::*;
fn test_query_id(value: u128) -> QueryId {