Struct BroadcastJoinOptions 

pub struct BroadcastJoinOptions {
    pub join_key_field: String,
    pub streaming_topic: Option<String>,
    pub name: Option<String>,
    pub max_bytes: Option<i64>,
    pub refresh_mode: Option<String>,
    pub interval_millis: Option<u32>,
}

Options for StreamBuilder::broadcast_join.

Fields

join_key_field: String

streaming_topic: Option<String>

name: Option<String>

max_bytes: Option<i64>

refresh_mode: Option<String>

Must be "cdc", "periodic", or "explicit".

interval_millis: Option<u32>

Trait Implementations

impl Clone for BroadcastJoinOptions

fn clone(&self) -> BroadcastJoinOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BroadcastJoinOptions

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

Formats the value using the given formatter.

impl Default for BroadcastJoinOptions

fn default() -> BroadcastJoinOptions

Returns the “default value” for a type.