org.apache.flink.ml.pipeline

Class PipelineStageBase<S extends PipelineStageBase<S>>

java.lang.Object

org.apache.flink.ml.pipeline.PipelineStageBase<S>

Type Parameters:

S - The class type of the PipelineStageBase implementation itself, used by WithParams and Cloneable.

All Implemented Interfaces:

Cloneable, WithParams<S>, HasMLEnvironmentId<S>

Direct Known Subclasses:

EstimatorBase, TransformerBase

public abstract class PipelineStageBase<S extends PipelineStageBase<S>>
extends Object
implements WithParams<S>, HasMLEnvironmentId<S>, Cloneable

The base class for a stage in a pipeline, either an [[EstimatorBase]] or a [[TransformerBase]].

The PipelineStageBase maintains the parameters for the stage. A default constructor is needed in order to restore a pipeline stage.

Field Summary

Fields

Modifier and Type	Field and Description
protected Params	params

Fields inherited from interface org.apache.flink.ml.params.shared.HasMLEnvironmentId

ML_ENVIRONMENT_ID

Constructor Summary

Constructors

Constructor and Description
PipelineStageBase()
PipelineStageBase(Params params)

Method Summary

Modifier and Type	Method and Description
S	clone()
Params	getParams() Returns the all the parameters.
protected static TableEnvironment	tableEnvOf(Table table)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.ml.params.shared.HasMLEnvironmentId

getMLEnvironmentId, setMLEnvironmentId

Methods inherited from interface org.apache.flink.ml.api.misc.param.WithParams

get, set

Field Detail

params

protected Params params

Constructor Detail

PipelineStageBase

public PipelineStageBase()

PipelineStageBase

public PipelineStageBase(Params params)

Method Detail

getParams

public Params getParams()

Description copied from interface: WithParams

Returns the all the parameters.

Specified by:

getParams in interface WithParams<S extends PipelineStageBase<S>>

Returns:

all the parameters.

clone

public S clone()
        throws CloneNotSupportedException

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

tableEnvOf

protected static TableEnvironment tableEnvOf(Table table)