Chains a label estimator onto the end of this pipeline, producing a new pipeline.
Chains a label estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
The labels to use when fitting the LabelEstimator. Must be zippable with the training data.
Chains a label estimator onto the end of this pipeline, producing a new pipeline.
Chains a label estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
The labels to use when fitting the LabelEstimator. Must be zippable with the training data.
Chains a label estimator onto the end of this pipeline, producing a new pipeline.
Chains a label estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
The labels to use when fitting the LabelEstimator. Must be zippable with the training data.
Chains a label estimator onto the end of this pipeline, producing a new pipeline.
Chains a label estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
The labels to use when fitting the LabelEstimator. Must be zippable with the training data.
Chains an estimator onto the end of this pipeline, producing a new pipeline.
Chains an estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
Chains an estimator onto the end of this pipeline, producing a new pipeline.
Chains an estimator onto the end of this pipeline, producing a new pipeline. If this pipeline has already been executed, it will not need to be fit again.
The estimator to chain onto the end of this pipeline
The training data to use (the estimator will be fit on the result of passing this data through the current pipeline)
Chains a pipeline onto the end of this one, producing a new pipeline.
Chains a pipeline onto the end of this one, producing a new pipeline. If either this pipeline or the following has already been executed, it will not need to be fit again.
the pipeline to chain
Lazily apply the pipeline to the lazy output of a different pipeline given an initial datum.
Lazily apply the pipeline to the lazy output of a different pipeline given an initial datum. If the previous pipeline has already been fit, it will not need to be fit again.
A lazy wrapper around the result of passing lazy output from a different pipeline through this pipeline.
Lazily apply the pipeline to the lazy output of a different pipeline given an initial dataset.
Lazily apply the pipeline to the lazy output of a different pipeline given an initial dataset. If the previous pipeline has already been fit, it will not need to be fit again.
A lazy wrapper around the result of passing lazy output from a different pipeline through this pipeline.
Lazily apply the pipeline to a dataset.
Lazily apply the pipeline to a dataset.
A lazy wrapper around the result of passing the dataset through the pipeline.
Lazily apply the pipeline to a single datum.
Lazily apply the pipeline to a single datum.
A lazy wrapper around the result of passing the datum through the pipeline.
Fit all Estimators in this pipeline to produce a FittedPipeline.
Fit all Estimators in this pipeline to produce a FittedPipeline. It is logically equivalent, but only contains Transformers in the underlying graph. Applying the FittedPipeline to new data does not trigger any new optimization or estimator fitting.
It is also serializable and may be written to and from disk.
the fitted version of this Pipeline.
A method that converts this object into a Pipeline.
A Pipeline takes data as input (single item or an RDD), and outputs some transformation of that data. Internally, a Pipeline contains a GraphExecutor, a specified source, and a specified sink. When a pipeline is applied to data it produces a PipelineResult, in the form of either a PipelineDataset or a PipelineDatum. These are lazy wrappers around the scheduled execution under the hood, and when their values are accessed the underlying Graph will be executed.
Warning: Not thread-safe!
type of the data this Pipeline expects as input
type of the data this Pipeline outputs