public class FValueTest extends Object implements AlgoOperator<FValueTest>, FValueTestParams<FValueTest>
The input of this algorithm is a table containing a labelColumn of numerical type and a featuresColumn of vector type. Each index in the input vector represents a feature to be tested. By default, the output of this algorithm is a table containing a single row with the following columns, each of which has one value per feature.
The output of this algorithm can be flattened to multiple rows by setting HasFlatten.FLATTEN
to true, which would contain the following columns:
FEATURES_COL
LABEL_COL
FLATTEN
Constructor and Description |
---|
FValueTest() |
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 FValueTest |
load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv,
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getFeaturesCol, setFeaturesCol
getLabelCol, setLabelCol
getFlatten, setFlatten
get, getParam, set
public org.apache.flink.table.api.Table[] transform(org.apache.flink.table.api.Table... inputs)
AlgoOperator
transform
in interface AlgoOperator<FValueTest>
inputs
- a list of tablespublic void save(String path) throws IOException
Stage
save
in interface Stage<FValueTest>
IOException
public static FValueTest load(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv, String path) throws IOException
IOException
public Map<Param<?>,Object> getParamMap()
WithParams
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.
getParamMap
in interface WithParams<FValueTest>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.