refactor: rename deduplicate --> overlap (#1779)
parent
0024f933df
commit
763ade390c
|
@ -16,7 +16,6 @@ use predicate::PredicateMatch;
|
||||||
|
|
||||||
use std::{fmt::Debug, sync::Arc};
|
use std::{fmt::Debug, sync::Arc};
|
||||||
|
|
||||||
pub mod duplicate;
|
|
||||||
pub mod exec;
|
pub mod exec;
|
||||||
pub mod frontend;
|
pub mod frontend;
|
||||||
pub mod func;
|
pub mod func;
|
||||||
|
|
|
@ -20,7 +20,6 @@ use internal_types::schema::{merge::SchemaMerger, Schema};
|
||||||
use observability_deps::tracing::debug;
|
use observability_deps::tracing::debug;
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
duplicate::group_potential_duplicates,
|
|
||||||
predicate::{Predicate, PredicateBuilder},
|
predicate::{Predicate, PredicateBuilder},
|
||||||
util::arrow_pk_sort_exprs,
|
util::arrow_pk_sort_exprs,
|
||||||
QueryChunk,
|
QueryChunk,
|
||||||
|
@ -30,8 +29,11 @@ use snafu::{ResultExt, Snafu};
|
||||||
|
|
||||||
mod adapter;
|
mod adapter;
|
||||||
mod deduplicate;
|
mod deduplicate;
|
||||||
|
mod overlap;
|
||||||
mod physical;
|
mod physical;
|
||||||
use self::{deduplicate::DeduplicateExec, physical::IOxReadFilterNode};
|
use self::{
|
||||||
|
deduplicate::DeduplicateExec, overlap::group_potential_duplicates, physical::IOxReadFilterNode,
|
||||||
|
};
|
||||||
|
|
||||||
#[derive(Debug, Snafu)]
|
#[derive(Debug, Snafu)]
|
||||||
pub enum Error {
|
pub enum Error {
|
||||||
|
@ -66,7 +68,7 @@ pub enum Error {
|
||||||
},
|
},
|
||||||
|
|
||||||
#[snafu(display("Internal error: Can not group chunks '{}'", source,))]
|
#[snafu(display("Internal error: Can not group chunks '{}'", source,))]
|
||||||
InternalChunkGrouping { source: crate::duplicate::Error },
|
InternalChunkGrouping { source: self::overlap::Error },
|
||||||
}
|
}
|
||||||
pub type Result<T, E = Error> = std::result::Result<T, E>;
|
pub type Result<T, E = Error> = std::result::Result<T, E>;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue