The replicator copy the data at input some specified number of times.
Argument name | Optional/mandatory | Description | Values/Examples |
type | mandatory | | type = "replicator" |
replication_factor | mandatory | How many copies of input data to make | replication_factor = 3 |
input_name | optional | the name of the input variable | input_name = "trace_segm" |
output_name | optional | the name of the output variable | output_name = "trace" |
Command | Input name | Input type | Output name | Output type | Specific attributes |
replicate | input_name or "input" | Any | output_name or "output" | Depends on type at input | |
[modules]
[modules.bacher]
type = "replicator"
replication_factor = "$(batch)"
output_name = "sync"
[actors]
create_batch = ["batcher", "replicate"]