Splitter: Initialize a splitter object

In sewage: A Light-Weight Data Pipelining Tool

Initialize a splitter object

Description

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

Details

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

Value

a sewage_splitter object

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

sewage documentation built on May 31, 2023, 9:29 p.m.