Enum EdgeId

pub(super) enum EdgeId {
    Internal {
        link_id: u64,
    },
    UpstreamExternal {
        upstream_table_id: TableId,
        downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>,
    },
    DownstreamExternal {
        original_upstream_fragment_id: GlobalId<{ IdCategory::Fragment }>,
        downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>,
    },
}

The ID of an edge in the fragment graph. For different types of edges, the ID will be in different variants.

Variants

Internal

The edge between two building (internal) fragments.

Fields

link_id: u64

The ID generated by the frontend, generally the operator ID of Exchange. See StreamFragmentEdgeProto.

UpstreamExternal

The edge between an upstream external fragment and downstream building fragment. Used for MV on MV.

Fields

upstream_table_id: TableId

The ID of the upstream table or materialized view.

downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>

The ID of the downstream fragment.

DownstreamExternal

The edge between an upstream building fragment and downstream external fragment. Used for schema change (replace table plan).

Fields

original_upstream_fragment_id: GlobalId<{ IdCategory::Fragment }>

The ID of the original upstream fragment (Materialize).

downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>

The ID of the downstream fragment.

Implementations

impl EdgeId

pub fn is_internal(&self) -> bool

Returns true if this is a EdgeId::Internal, otherwise false

pub fn as_internal_mut(&mut self) -> Option<&mut u64>

Optionally returns mutable references to the inner fields if this is a EdgeId::Internal, otherwise None

pub fn as_internal(&self) -> Option<&u64>

Optionally returns references to the inner fields if this is a EdgeId::Internal, otherwise None

pub fn into_internal(self) -> Result<u64, Self>

Returns the inner fields if this is a EdgeId::Internal, otherwise returns back the enum in the Err case of the result

pub fn is_upstream_external(&self) -> bool

Returns true if this is a EdgeId::UpstreamExternal, otherwise false

pub fn as_upstream_external_mut( &mut self, ) -> Option<(&mut TableId, &mut GlobalId<{ IdCategory::Fragment }>)>

Optionally returns mutable references to the inner fields if this is a EdgeId::UpstreamExternal, otherwise None

pub fn as_upstream_external( &self, ) -> Option<(&TableId, &GlobalId<{ IdCategory::Fragment }>)>

Optionally returns references to the inner fields if this is a EdgeId::UpstreamExternal, otherwise None

pub fn into_upstream_external( self, ) -> Result<(TableId, GlobalId<{ IdCategory::Fragment }>), Self>

Returns the inner fields if this is a EdgeId::UpstreamExternal, otherwise returns back the enum in the Err case of the result

pub fn is_downstream_external(&self) -> bool

Returns true if this is a EdgeId::DownstreamExternal, otherwise false

pub fn as_downstream_external_mut( &mut self, ) -> Option<(&mut GlobalId<{ IdCategory::Fragment }>, &mut GlobalId<{ IdCategory::Fragment }>)>

Optionally returns mutable references to the inner fields if this is a EdgeId::DownstreamExternal, otherwise None

pub fn as_downstream_external( &self, ) -> Option<(&GlobalId<{ IdCategory::Fragment }>, &GlobalId<{ IdCategory::Fragment }>)>

Optionally returns references to the inner fields if this is a EdgeId::DownstreamExternal, otherwise None

pub fn into_downstream_external( self, ) -> Result<(GlobalId<{ IdCategory::Fragment }>, GlobalId<{ IdCategory::Fragment }>), Self>

Returns the inner fields if this is a EdgeId::DownstreamExternal, otherwise returns back the enum in the Err case of the result

Trait Implementations

impl Clone for EdgeId

fn clone(&self) -> EdgeId

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EdgeId

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

Formats the value using the given formatter.

impl Hash for EdgeId

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 EdgeId

fn eq(&self, other: &EdgeId) -> 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 Copy for EdgeId

impl Eq for EdgeId

impl StructuralPartialEq for EdgeId