sewage (version 0.2.5)

Splitter: Initialize a splitter object

Description

Splitter takes in exactly one input node and propogates the input to n output nodes.

Usage

Splitter(edges = 2)

Value

a sewage_splitter object

Arguments

edges

number out outputs. Must be greater than 1

Details

After executing a Splitter object, the pipeline will contains n outputs and will be named as SplitterName_output{i}.

Examples

pipeline = Pipeline()
pipeline = pipeline |>
    add_node(name = 'Splitter', component = Splitter(), input = 'file')
result = run(pipeline, file = mtcars)
pull_output(result, 'Splitter.output_1')
pull_output(result, 'Splitter.output_2')