Struct WatermarkColumns

pub struct WatermarkColumns {
    col_idx_to_wtmk_group_id: BTreeMap<usize, WatermarkGroupId>,
}

Represents the output watermark columns of a plan node.

Fields

col_idx_to_wtmk_group_id: BTreeMap<usize, WatermarkGroupId>

Implementations

impl WatermarkColumns

pub fn new() -> Self

Create an empty WatermarkColumns.

pub fn is_empty(&self) -> bool

Check if the WatermarkColumns is empty.

pub fn n_indices(&self) -> usize

Get the number of watermark columns.

pub fn insert(&mut self, col_idx: usize, group: WatermarkGroupId)

Insert a column index with a watermark group ID.

pub fn contains(&self, col_idx: usize) -> bool

Check if the WatermarkColumns contains a column index.

pub fn get_group(&self, col_idx: usize) -> Option<WatermarkGroupId>

Get the watermark group ID of a column index.

pub fn index_set(&self) -> IndexSet

Get all watermark columns as a IndexSet.

pub fn indices(&self) -> impl Iterator<Item = usize> + '_

Iterate over all column indices, in ascending order.

pub fn grouped(&self) -> BTreeMap<WatermarkGroupId, IndexSet>

Get all watermark groups and their corresponding column indices.

pub fn iter(&self) -> impl Iterator<Item = (usize, WatermarkGroupId)> + '_

Iterate over all column indices and their corresponding watermark group IDs, in ascending order.

pub fn right_shift_clone(&self, column_shift: usize) -> Self

Clone and shift the column indices to the right (larger) by column_shift.

pub fn retain_clone(&self, col_indices: &[usize]) -> Self

Clone and retain only the columns with indices in col_indices.

pub fn map_clone(&self, col_mapping: &ColIndexMapping) -> Self

Clone and map the column indices using col_mapping.

Trait Implementations

impl Clone for WatermarkColumns

fn clone(&self) -> WatermarkColumns

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WatermarkColumns

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WatermarkColumns

fn default() -> WatermarkColumns

Returns the “default value” for a type.

impl Hash for WatermarkColumns

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for WatermarkColumns

fn eq(&self, other: &WatermarkColumns) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for WatermarkColumns

impl StructuralPartialEq for WatermarkColumns