org.apache.flink.ml.benchmark.datagenerator.common

Class InputTableGenerator<T extends InputTableGenerator<T>>

java.lang.Object

org.apache.flink.ml.benchmark.datagenerator.common.InputTableGenerator<T>

All Implemented Interfaces:

DataGenerator<T>, InputDataGenerator<T>, HasSeed<T>, WithParams<T>

Direct Known Subclasses:

DenseVectorArrayGenerator, DenseVectorGenerator, DoubleGenerator, LabeledPointWithWeightGenerator, RandomStringArrayGenerator, RandomStringGenerator

public abstract class InputTableGenerator<T extends InputTableGenerator<T>>
extends Object
implements InputDataGenerator<T>

Base class for generating data as input table arrays.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Param<?>,Object>	paramMap

Fields inherited from interface org.apache.flink.ml.benchmark.datagenerator.InputDataGenerator

COL_NAMES, NUM_VALUES

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

SEED

Constructor Summary

Constructors

Constructor and Description
InputTableGenerator()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.api.Table[]	getData(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv) Gets an array of Tables containing the data generated in the provided stream table environment.
Map<Param<?>,Object>	getParamMap() Returns a map which should contain value for every parameter that meets one of the following conditions.
protected abstract RowGenerator[]	getRowGenerators() Gets generators for all input 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.benchmark.datagenerator.InputDataGenerator

getColNames, getNumValues, setColNames, setNumValues

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

getSeed, setSeed

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

get, getParam, set

Field Detail

paramMap

protected final Map<Param<?>,Object> paramMap

Constructor Detail

InputTableGenerator

public InputTableGenerator()

Method Detail

getData

public final org.apache.flink.table.api.Table[] getData(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv)

Description copied from interface: DataGenerator

Gets an array of Tables containing the data generated in the provided stream table environment.

Specified by:

getData in interface DataGenerator<T extends InputTableGenerator<T>>

getRowGenerators

protected abstract RowGenerator[] getRowGenerators()

Gets generators for all input tables.

getParamMap

public final 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<T extends InputTableGenerator<T>>

Returns:

A map which maps parameter definition to parameter value.