Struct SourceConf 

pub struct SourceConf<S: ArconType> {
    pub extractor: Option<TimestampExtractor<S>>,
    pub time: ArconTime,
    pub batch_size: usize,
    pub name: String,
}

Source Configuration

Fields

extractor: Option<TimestampExtractor<S>>

time: ArconTime

batch_size: usize

name: String

Implementations

impl<S: ArconType> SourceConf<S>

pub fn set_arcon_time(&mut self, time: ArconTime)

Set ArconTime to be used for a Source

pub fn set_timestamp_extractor( &mut self, f: impl Fn(&S) -> u64 + Send + Sync + 'static, )

Set a Timestamp Extractor for a Source

pub fn set_batch_size(&mut self, size: usize)

pub fn set_source_name(&mut self, name: String)

Trait Implementations

impl<S: Clone + ArconType> Clone for SourceConf<S>

fn clone(&self) -> SourceConf<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: ArconType> Default for SourceConf<S>

fn default() -> Self

Returns the “default value” for a type.