hub / github.com/cda-group/arcon / create_source_node

Function create_source_node

arcon/src/dataflow/constructor.rs:476–509 · view source on GitHub ↗

helper function to create source node..

(
    app: &mut Application,
    channel_strategy: ChannelStrategy<S::Item>,
    source_index: usize,
    source: S,
    source_conf: SourceConf<S::Item>,
    source_manager_comp: &Arc<Component<Sourc

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 1

build_sourceMethod · 0.85

Calls 4

cloneMethod · 0.80

data_systemMethod · 0.80

add_sourceMethod · 0.80

createMethod · 0.45

Tested by

no test coverage detected