org.apache.spark.ml

Class PipelineStage

Object

org.apache.spark.ml.PipelineStage

All Implemented Interfaces:

java.io.Serializable, Logging

Direct Known Subclasses:

Estimator, Transformer

public abstract class PipelineStage
extends Object
implements scala.Serializable, Logging

:: AlphaComponent :: A stage in a pipeline, either an Estimator or a Transformer.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PipelineStage()

Method Summary

Methods

Modifier and Type	Method and Description
abstract org.apache.spark.sql.types.StructType	transformSchema(org.apache.spark.sql.types.StructType schema, ParamMap paramMap) :: DeveloperAPI ::

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

PipelineStage

public PipelineStage()

Method Detail

transformSchema

public abstract org.apache.spark.sql.types.StructType transformSchema(org.apache.spark.sql.types.StructType schema,
                                                    ParamMap paramMap)

:: DeveloperAPI ::

Derives the output schema from the input schema and parameters. The schema describes the columns and types of the data.

Parameters:

schema - Input schema to this stage

paramMap - Parameters passed to this stage

Returns:

Output schema from this stage