org.apache.flink.ml.api

Interface AlgoOperator<T extends AlgoOperator<T>>

Type Parameters:

T - The class type of the AlgoOperator implementation itself.

All Superinterfaces:

Serializable, Stage<T>, WithParams<T>

All Known Subinterfaces:

Model<T>, Transformer<T>

All Known Implementing Classes:

GraphModel, KMeansModel, KnnModel, LogisticRegressionModel, NaiveBayesModel, OneHotEncoderModel, PipelineModel

@PublicEvolving
public interface AlgoOperator<T extends AlgoOperator<T>>
extends Stage<T>

An AlgoOperator takes a list of tables as inputs and produces a list of tables as results. It can be used to encode generic multi-input multi-output computation logic.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.api.Table[]	transform(org.apache.flink.table.api.Table... inputs) Applies the AlgoOperator on the given input tables and returns the result tables.

Methods inherited from interface org.apache.flink.ml.api.Stage

save

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

get, getParam, getParamMap, set

Method Detail

transform

org.apache.flink.table.api.Table[] transform(org.apache.flink.table.api.Table... inputs)

Applies the AlgoOperator on the given input tables and returns the result tables.

Parameters:

inputs - a list of tables

Returns:

a list of tables