Package direct contains the direct runner for running single-bundle pipelines in the current process. Useful for testing.
Compile translates a pipeline to a multi-bundle execution plan.
Execute runs the pipeline in-process.
CoGBK buffers all input and continues on FinishBundle. Use with small single-bundle data only.
Impulse emits its single element in one invocation.
Inject injects the predecessor index into each FullValue, effectively converting KV<X,Y> into KV<X,KV<int,Y>>. Used to prime CoGBK.