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.Pipes
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.Pipefor more information.