Package | Description |
---|---|
org.apache.flink.ml | |
org.apache.flink.ml.optimization | |
org.apache.flink.ml.preprocessing | |
org.apache.flink.ml.regression |
Modifier and Type | Method and Description |
---|---|
static DataSet<LabeledVector> |
MLUtils.readLibSVM(ExecutionEnvironment env,
String filePath)
Reads a file in libSVM/SVMLight format and converts the data into a data set of
LabeledVector . |
DataSet<LabeledVector> |
MLUtils$.readLibSVM(ExecutionEnvironment env,
String filePath)
Reads a file in libSVM/SVMLight format and converts the data into a data set of
LabeledVector . |
Modifier and Type | Method and Description |
---|---|
static DataSink<String> |
MLUtils.writeLibSVM(String filePath,
DataSet<LabeledVector> labeledVectors)
Writes a
DataSet of LabeledVector to a file using the libSVM/SVMLight format. |
DataSink<String> |
MLUtils$.writeLibSVM(String filePath,
DataSet<LabeledVector> labeledVectors)
Writes a
DataSet of LabeledVector to a file using the libSVM/SVMLight format. |
Modifier and Type | Method and Description |
---|---|
WeightVector |
LossFunction.gradient(LabeledVector dataPoint,
WeightVector weightVector)
Calculates the gradient of the loss function given a data point and weight vector
|
double |
LossFunction.loss(LabeledVector dataPoint,
WeightVector weightVector)
Calculates the loss given the prediction and label value
|
scala.Tuple2<Object,WeightVector> |
LossFunction.lossGradient(LabeledVector dataPoint,
WeightVector weightVector)
Calculates the gradient as well as the loss given a data point and the weight vector
|
scala.Tuple2<Object,WeightVector> |
GenericLossFunction.lossGradient(LabeledVector dataPoint,
WeightVector weightVector)
Calculates the gradient as well as the loss given a data point and the weight vector
|
Modifier and Type | Method and Description |
---|---|
DataSet<WeightVector> |
Solver.createInitialWeightsDS(scala.Option<DataSet<WeightVector>> initialWeights,
DataSet<LabeledVector> data)
Creates initial weights vector, creating a DataSet with a WeightVector element
|
DataSet<WeightVector> |
GradientDescent.optimize(DataSet<LabeledVector> data,
scala.Option<DataSet<WeightVector>> initialWeights)
Provides a solution for the given optimization problem
|
abstract DataSet<WeightVector> |
Solver.optimize(DataSet<LabeledVector> data,
scala.Option<DataSet<WeightVector>> initialWeights)
Provides a solution for the given optimization problem
|
DataSet<WeightVector> |
GradientDescent.optimizeWithConvergenceCriterion(DataSet<LabeledVector> dataPoints,
DataSet<WeightVector> initialWeightsDS,
int numberOfIterations,
double regularizationConstant,
double learningRate,
double convergenceThreshold,
LossFunction lossFunction,
LearningRateMethod.LearningRateMethodTrait learningRateMethod) |
DataSet<WeightVector> |
GradientDescent.optimizeWithoutConvergenceCriterion(DataSet<LabeledVector> data,
DataSet<WeightVector> initialWeightsDS,
int numberOfIterations,
double regularizationConstant,
double learningRate,
LossFunction lossFunction,
LearningRateMethod.LearningRateMethodTrait optimizationMethod) |
Modifier and Type | Method and Description |
---|---|
StandardScaler.StandardScalerTransformOperation<LabeledVector> |
StandardScaler$.transformLabeledVector()
TransformOperation to transform LabeledVector . |
static StandardScaler.StandardScalerTransformOperation<LabeledVector> |
StandardScaler.transformLabeledVector()
TransformOperation to transform LabeledVector . |
Modifier and Type | Method and Description |
---|---|
DataSet<Object> |
MultipleLinearRegression.squaredResidualSum(DataSet<LabeledVector> input) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.