public class NaiveBayesModelData extends Object
NaiveBayesModel.
This class also provides methods to convert model data from Table to Datastream, and classes to save/load model data.
| 限定符和类型 | 类和说明 |
|---|---|
static class |
NaiveBayesModelData.ModelDataDecoder
Data decoder for the
NaiveBayesModelData. |
static class |
NaiveBayesModelData.ModelDataEncoder
Data encoder for the
NaiveBayesModelData. |
| 限定符和类型 | 字段和说明 |
|---|---|
org.apache.flink.ml.linalg.DenseVector |
labels
Value of labels.
|
org.apache.flink.ml.linalg.DenseVector |
piArray
Log of class priors, whose dimension is C (number of classes).
|
Map<Double,Double>[][] |
theta
Log of class conditional probabilities, whose dimension is C (number of classes) by D (number
of features).
|
| 构造器和说明 |
|---|
NaiveBayesModelData() |
NaiveBayesModelData(Map<Double,Double>[][] theta,
org.apache.flink.ml.linalg.DenseVector piArray,
org.apache.flink.ml.linalg.DenseVector labels) |
| 限定符和类型 | 方法和说明 |
|---|---|
static org.apache.flink.streaming.api.datastream.DataStream<NaiveBayesModelData> |
getModelDataStream(org.apache.flink.table.api.Table modelData)
Converts the table model to a data stream.
|
public Map<Double,Double>[][] theta
public org.apache.flink.ml.linalg.DenseVector piArray
public org.apache.flink.ml.linalg.DenseVector labels
public NaiveBayesModelData(Map<Double,Double>[][] theta, org.apache.flink.ml.linalg.DenseVector piArray, org.apache.flink.ml.linalg.DenseVector labels)
public NaiveBayesModelData()
public static org.apache.flink.streaming.api.datastream.DataStream<NaiveBayesModelData> getModelDataStream(org.apache.flink.table.api.Table modelData)
modelData - The table model data.Copyright © 2019–2021 The Apache Software Foundation. All rights reserved.