pub struct FunctionalDependencySet {
column_count: usize,
strict: Vec<FunctionalDependency>,
}
Expand description
FunctionalDependencySet
contains the functional dependencies.
It is used in optimizer to track the dependencies between columns.
Fields§
§column_count: usize
the number of columns
strict: Vec<FunctionalDependency>
strict
contains all strict functional dependencies.
The strict functional dependency use the NULL= semantic. It means that all NULLs are considered as equal. So for following table, A –> B is not valid. NOT allowed.
A | B
------|---
NULL | 1
NULL | 2
Currently we only have strict dependencies, but we may also have lax dependencies in the future.
Implementations§
source§impl FunctionalDependencySet
impl FunctionalDependencySet
sourcepub fn new(column_count: usize) -> Self
pub fn new(column_count: usize) -> Self
Create an empty FunctionalDependencySet
sourcepub fn with_key(column_cnt: usize, key_indices: &[usize]) -> Self
pub fn with_key(column_cnt: usize, key_indices: &[usize]) -> Self
Create a FunctionalDependencySet
with the indices of a key.
The combination of these columns can determine all other columns.
sourcepub fn with_dependencies(
column_count: usize,
strict_dependencies: Vec<FunctionalDependency>,
) -> Self
pub fn with_dependencies( column_count: usize, strict_dependencies: Vec<FunctionalDependency>, ) -> Self
Create a FunctionalDependencySet
with a dependency Vec
pub fn as_dependencies_mut(&mut self) -> &mut Vec<FunctionalDependency>
pub fn as_dependencies(&self) -> &Vec<FunctionalDependency>
pub fn into_dependencies(self) -> Vec<FunctionalDependency>
sourcepub fn add_functional_dependency(&mut self, fd: FunctionalDependency)
pub fn add_functional_dependency(&mut self, fd: FunctionalDependency)
Add a functional dependency to a FunctionalDependencySet
.
sourcepub fn add_key(&mut self, key_indices: &[usize])
pub fn add_key(&mut self, key_indices: &[usize])
Add key columns to a FunctionalDependencySet
.
sourcepub fn add_constant_columns(&mut self, constant_columns: &[usize])
pub fn add_constant_columns(&mut self, constant_columns: &[usize])
Add constant columns to a FunctionalDependencySet
.
sourcepub fn add_functional_dependency_by_column_indices(
&mut self,
from: &[usize],
to: &[usize],
)
pub fn add_functional_dependency_by_column_indices( &mut self, from: &[usize], to: &[usize], )
Add a dependency to FunctionalDependencySet
using column indices.
sourcefn get_closure(&self, columns: &FixedBitSet) -> FixedBitSet
fn get_closure(&self, columns: &FixedBitSet) -> FixedBitSet
O(d), where d
is the number of functional dependencies.
The call to is_subset
is technically O(n),
but we can consider it O(1) since the constant factor is 1/usize.
sourcepub fn is_determined_by(
&self,
determinant: &FixedBitSet,
dependant: &FixedBitSet,
) -> bool
pub fn is_determined_by( &self, determinant: &FixedBitSet, dependant: &FixedBitSet, ) -> bool
Return true
if the dependency determinant -> dependant exists.
O(d), where the dominant cost is from Self::get_closure
, which has O(d) complexity.
sourcefn is_key_inner(&self, columns: &FixedBitSet) -> bool
fn is_key_inner(&self, columns: &FixedBitSet) -> bool
This just checks if the columns specified by the columns
bitset
determines each other column.
sourcepub fn is_key(&self, columns: &[usize]) -> bool
pub fn is_key(&self, columns: &[usize]) -> bool
Return true if the combination of columns
can fully determine other columns.
sourcepub fn minimize_key(&self, key_indices: &[usize]) -> Vec<usize>
pub fn minimize_key(&self, key_indices: &[usize]) -> Vec<usize>
This is just a wrapper around Self::minimize_key_bitset
to minimize key_indices
.
sourcefn minimize_key_bitset(&self, key: FixedBitSet) -> FixedBitSet
fn minimize_key_bitset(&self, key: FixedBitSet) -> FixedBitSet
§Overview
Remove redundant columns from the given set.
Redundant columns can be functionally determined by other columns so there is no need to keep them in a key.
Note that the accurate minimization algorithm can take O(2^n) time,
so we use a approximate algorithm which use O(cn) time. c
is the number of columns, and
n
is the number of functional dependency rules.
This algorithm may not necessarily find the key with the least number of columns. But it will ensure that no redundant columns will be preserved.
§Algorithm
This algorithm removes columns one by one and check whether the remaining columns can form a key or not. If the remaining columns can form a key, then this column can be removed.
sourcepub fn minimize_order_key(
&self,
order_key: Order,
dist_key_indices: &[usize],
) -> Order
pub fn minimize_order_key( &self, order_key: Order, dist_key_indices: &[usize], ) -> Order
Wrapper around Self::minimize_order_key_bitset
to minimize order_key
.
View the documentation of Self::minimize_order_key_bitset
for more information.
In the process of minimizing the order key,
we must ensure that if the indices are part of
distribution key, they must not be pruned.
sourcefn minimize_order_key_bitset(&self, order_key: Vec<usize>) -> FixedBitSet
fn minimize_order_key_bitset(&self, order_key: Vec<usize>) -> FixedBitSet
- Iterate over the prefixes of the order key.
- If some continuous subset of columns and the next column of the order key form a functional dependency, we can prune that column.
- This function has O(dn) complexity, where:
i.
d
is the number of functional dependencies, because each iteration in the loop callsSelf::is_determined_by
. ii.n
is the number of columns.
Trait Implementations§
source§impl Clone for FunctionalDependencySet
impl Clone for FunctionalDependencySet
source§fn clone(&self) -> FunctionalDependencySet
fn clone(&self) -> FunctionalDependencySet
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for FunctionalDependencySet
impl Debug for FunctionalDependencySet
source§impl Default for FunctionalDependencySet
impl Default for FunctionalDependencySet
source§fn default() -> FunctionalDependencySet
fn default() -> FunctionalDependencySet
source§impl Display for FunctionalDependencySet
impl Display for FunctionalDependencySet
source§impl Hash for FunctionalDependencySet
impl Hash for FunctionalDependencySet
source§impl PartialEq for FunctionalDependencySet
impl PartialEq for FunctionalDependencySet
impl Eq for FunctionalDependencySet
impl StructuralPartialEq for FunctionalDependencySet
Auto Trait Implementations§
impl Freeze for FunctionalDependencySet
impl RefUnwindSafe for FunctionalDependencySet
impl Send for FunctionalDependencySet
impl Sync for FunctionalDependencySet
impl Unpin for FunctionalDependencySet
impl UnwindSafe for FunctionalDependencySet
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)§impl<T> Conv for T
impl<T> Conv for T
§impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
§impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
impl<T, U, I> LiftInto<U, I> for Twhere
U: LiftFrom<T, I>,
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<Source> Sculptor<HNil, HNil> for Source
impl<Source> Sculptor<HNil, HNil> for Source
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.