An immutable chain of sequential operations which can be extended, forming a new Pipe.
An immutable chain of sequential operations which can be extended, forming a new Pipe. It can also be run, producing an output value which is cached after the first run.
Factory for software.uncharted.sparkpipe.Pipe
s
from various inputs, such as raw values or other Pipes
This package contains a pipeline implementation for Spark See the README or
software.uncharted.sparkpipe.Pipe
for more information.