org.apache.flink.ml.feature.normalizer

Class Normalizer

java.lang.Object

org.apache.flink.ml.feature.normalizer.Normalizer

All Implemented Interfaces:

Serializable, AlgoOperator<Normalizer>, Stage<Normalizer>, Transformer<Normalizer>, HasInputCol<Normalizer>, HasOutputCol<Normalizer>, NormalizerParams<Normalizer>, WithParams<Normalizer>

public class Normalizer
extends Object
implements Transformer<Normalizer>, NormalizerParams<Normalizer>

A Transformer that normalizes a vector to have unit norm using the given p-norm.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.flink.ml.feature.normalizer.NormalizerParams

P

Fields inherited from interface org.apache.flink.ml.common.param.HasInputCol

INPUT_COL

Fields inherited from interface org.apache.flink.ml.common.param.HasOutputCol

OUTPUT_COL

Constructor Summary

Constructors

Constructor and Description
Normalizer()

Method Summary

Modifier and Type	Method and Description
Map<Param<?>,Object>	getParamMap() Returns a map which should contain value for every parameter that meets one of the following conditions.
static Normalizer	load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment env, String path)
void	save(String path) Saves the metadata and bounded data of this stage to the given path.
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 class java.lang.Object

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

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

get, getParam, set

Methods inherited from interface org.apache.flink.ml.feature.normalizer.NormalizerParams

getP, setP

Methods inherited from interface org.apache.flink.ml.common.param.HasInputCol

getInputCol, setInputCol

Methods inherited from interface org.apache.flink.ml.common.param.HasOutputCol

getOutputCol, setOutputCol

Constructor Detail

Normalizer

public Normalizer()

Method Detail

transform

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

Description copied from interface: AlgoOperator

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

Specified by:

transform in interface AlgoOperator<Normalizer>

Parameters:

inputs - a list of tables

Returns:

a list of tables

save

public void save(String path)
          throws IOException

Description copied from interface: Stage

Saves the metadata and bounded data of this stage to the given path.

Specified by:

save in interface Stage<Normalizer>

Throws:

IOException

load

public static Normalizer load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment env,
                              String path)
                       throws IOException

Throws:

IOException

getParamMap

public Map<Param<?>,Object> getParamMap()

Description copied from interface: WithParams

Returns a map which should contain value for every parameter that meets one of the following conditions.

1) set(...) has been called to set value for this parameter.

2) The parameter is a public final field of this WithParams instance. This includes fields inherited from its interfaces and super-classes.

The subclass which implements this interface could meet this requirement by returning a member field of the given map type, after having initialized this member field using the ParamUtils.initializeMapWithDefaultValues(Map, WithParams) method.

Specified by:

getParamMap in interface WithParams<Normalizer>

Returns:

A map which maps parameter definition to parameter value.