Struct FlowInfoValue

pub struct FlowInfoValue {
    pub(crate) source_table_ids: Vec<TableId>,
    pub(crate) sink_table_name: TableName,
    pub(crate) flownode_ids: BTreeMap<FlowPartitionId, FlownodeId>,
    pub(crate) catalog_name: String,
    pub(crate) flow_name: String,
    pub(crate) raw_sql: String,
    pub(crate) expire_after: Option<i64>,
    pub(crate) comment: String,
    pub(crate) options: HashMap<String, String>,
}

Fields

source_table_ids: Vec<TableId>

The source tables used by the flow.

sink_table_name: TableName

The sink table used by the flow.

flownode_ids: BTreeMap<FlowPartitionId, FlownodeId>

Which flow nodes this flow is running on.

catalog_name: String

The catalog name.

flow_name: String

The flow name.

raw_sql: String

The raw sql.

expire_after: Option<i64>

The expr of expire. Duration in seconds as i64.

comment: String

The comment.

options: HashMap<String, String>

The options.

Implementations

impl FlowInfoValue

pub fn flownode_ids(&self) -> &BTreeMap<FlowPartitionId, FlownodeId>

Returns the flownode_id.

pub fn source_table_ids(&self) -> &[TableId]

Returns the source_table.

pub fn catalog_name(&self) -> &String

pub fn flow_name(&self) -> &String

pub fn sink_table_name(&self) -> &TableName

pub fn raw_sql(&self) -> &String

pub fn expire_after(&self) -> Option<i64>

pub fn comment(&self) -> &String

pub fn options(&self) -> &HashMap<String, String>

Trait Implementations

impl Clone for FlowInfoValue

fn clone(&self) -> FlowInfoValue

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FlowInfoValue

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FlowInfoValue

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl MetadataValue for FlowInfoValue

fn try_from_raw_value(raw_value: &[u8]) -> Result<Self>

fn try_as_raw_value(&self) -> Result<Vec<u8>>

impl PartialEq for FlowInfoValue

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FlowInfoValue