public class LogisticRegressionModelDataUtil extends Object
Modifier and Type | Class and Description |
---|---|
static class |
LogisticRegressionModelDataUtil.ModelDataDecoder
Data decoder for
LogisticRegression and OnlineLogisticRegression . |
static class |
LogisticRegressionModelDataUtil.ModelDataEncoder
Data encoder for
LogisticRegression and OnlineLogisticRegression . |
Constructor and Description |
---|
LogisticRegressionModelDataUtil() |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.table.api.Table |
generateRandomModelData(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv,
int dim,
int seed)
Generates a Table containing a
LogisticRegressionModelData instance with randomly
generated coefficient. |
static org.apache.flink.streaming.api.datastream.DataStream<byte[]> |
getModelDataByteStream(org.apache.flink.table.api.Table modelDataTable)
Converts the table model to a data stream of bytes.
|
static org.apache.flink.streaming.api.datastream.DataStream<LogisticRegressionModelData> |
getModelDataStream(org.apache.flink.table.api.Table modelData)
Converts the table model to a data stream.
|
public static org.apache.flink.table.api.Table generateRandomModelData(org.apache.flink.table.api.bridge.java.StreamTableEnvironment tEnv, int dim, int seed)
LogisticRegressionModelData
instance with randomly
generated coefficient.tEnv
- The environment where to create the table.dim
- The size of generated coefficient.seed
- Random seed.public static org.apache.flink.streaming.api.datastream.DataStream<LogisticRegressionModelData> getModelDataStream(org.apache.flink.table.api.Table modelData)
modelData
- The table model data.public static org.apache.flink.streaming.api.datastream.DataStream<byte[]> getModelDataByteStream(org.apache.flink.table.api.Table modelDataTable)
modelDataTable
- The table of model data.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.