org.apache.flink.ml.api.core

Interface Transformer<T extends Transformer<T>>

Type Parameters:

T - The class type of the Transformer implementation itself, used by WithParams

All Known Subinterfaces:

Model<M>

All Known Implementing Classes:

Pipeline

@PublicEvolving
public interface Transformer<T extends Transformer<T>>

A transformer is a PipelineStage that transforms an input Table to a result Table.

Method Summary

Modifier and Type	Method and Description
default void	loadJson(String json)
default String	toJson()
Table	transform(TableEnvironment tEnv, Table input) Applies the transformer on the input table, and returns the result table.

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

get, getParams, set

Method Detail

transform

Table transform(TableEnvironment tEnv,
                Table input)

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

Parameters:

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

input - the table to be transformed

Returns:

the transformed table

toJson

default String toJson()

loadJson

default void loadJson(String json)