org.apache.flink.ml.pipeline

Class TransformerBase<T extends TransformerBase<T>>

java.lang.Object

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

org.apache.flink.ml.pipeline.TransformerBase<T>

Type Parameters:

T - A subclass of TransformerBase, used by WithParams

All Implemented Interfaces:

Cloneable, Transformer<T>, WithParams<T>, HasMLEnvironmentId<T>

Direct Known Subclasses:

ModelBase

public abstract class TransformerBase<T extends TransformerBase<T>>
extends PipelineStageBase<T>
implements Transformer<T>

The base class for transformer implementations.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.ml.pipeline.PipelineStageBase

params

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

ML_ENVIRONMENT_ID

Constructor Summary

Constructors

Constructor and Description
TransformerBase()
TransformerBase(Params params)

Method Summary

Modifier and Type	Method and Description
default void	loadJson(String json)
default String	toJson()
protected abstract BatchOperator	transform(BatchOperator input) Applies the transformer on the input batch data from BatchOperator, and returns the batch result data with BatchOperator.
protected abstract StreamOperator	transform(StreamOperator input) Applies the transformer on the input streaming data from StreamOperator, and returns the streaming result data with StreamOperator.
Table	transform(Table input) Applies the transformer on the input table, and returns the result table.
Table	transform(TableEnvironment tEnv, Table input) Applies the transformer on the input table, and returns the result table.

Methods inherited from class org.apache.flink.ml.pipeline.PipelineStageBase

clone, getParams, tableEnvOf

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.api.misc.param.WithParams

get, getParams, set

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

getMLEnvironmentId, setMLEnvironmentId

Constructor Detail

TransformerBase

public TransformerBase()

TransformerBase

public TransformerBase(Params params)

Method Detail

transform

public Table transform(TableEnvironment tEnv,
                       Table input)

Description copied from interface: Transformer

Applies the transformer on the input table, and returns the result table.

Specified by:

transform in interface Transformer<T extends TransformerBase<T>>

Parameters:

tEnv - the table environment to which the input table is bound.

input - the table to be transformed

Returns:

the transformed table

transform

public Table transform(Table input)

Applies the transformer on the input table, and returns the result table.

Parameters:

input - the table to be transformed

Returns:

the transformed table

transform

protected abstract BatchOperator transform(BatchOperator input)

Applies the transformer on the input batch data from BatchOperator, and returns the batch result data with BatchOperator.

Parameters:

input - the input batch data from BatchOperator

Returns:

the transformed batch result data

transform

protected abstract StreamOperator transform(StreamOperator input)

Applies the transformer on the input streaming data from StreamOperator, and returns the streaming result data with StreamOperator.

Parameters:

input - the input streaming data from StreamOperator

Returns:

the transformed streaming result data

toJson

public String toJson()

loadJson

public void loadJson(String json)