Initialize a splitter object

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

Usage

Splitter(edges = 2)

Arguments

edges

number out outputs. Must be greater than 1

Value

a sewage_splitter object

Details

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

Note

The ouputs of a Splitter object are accessed through the naming convention {name}.output_{i} where name is the specified name of the Splitter object. This allows you to pass split objects to downstream nodes or access them through the pipeline results.

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')