fork
Executes a subpipeline with a copy of the input.
fork { … }Description
Section titled “Description”The fork operator execute a subpipeline with a copy its input, that is:
whenever an event arrives, it is send both to the given pipeline and forwarded
at the same time to the next operator.
The pipeline to execute. Must have a sink.
Examples
Section titled “Examples”Publish incoming events while importing them simultaneously
Section titled “Publish incoming events while importing them simultaneously”fork { publish "imported-events"}import