Package | Description |
---|---|
org.apache.flink.ml.common | |
org.apache.flink.ml.common.utils |
Modifier and Type | Method and Description |
---|---|
static MLEnvironment |
MLEnvironmentFactory.get(Long mlEnvId)
Get the MLEnvironment using a MLEnvironmentId.
|
static MLEnvironment |
MLEnvironmentFactory.getDefault()
Get the MLEnvironment use the default MLEnvironmentId.
|
static MLEnvironment |
MLEnvironmentFactory.remove(Long mlEnvId)
Remove the MLEnvironment using the MLEnvironmentId.
|
Modifier and Type | Method and Description |
---|---|
static Long |
MLEnvironmentFactory.registerMLEnvironment(MLEnvironment env)
Register a new MLEnvironment to the factory and return a new MLEnvironment id.
|
Modifier and Type | Method and Description |
---|---|
static Table |
DataSetConversionUtil.toTable(MLEnvironment session,
DataSet<Row> data,
String[] colNames)
Convert the given DataSet into a Table with specified colNames.
|
static Table |
DataSetConversionUtil.toTable(MLEnvironment session,
DataSet<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataSet into a Table with specified colNames and colTypes.
|
static Table |
DataStreamConversionUtil.toTable(MLEnvironment session,
DataStream<Row> data,
String[] colNames)
Convert the given DataStream to Table with specified colNames.
|
static Table |
DataStreamConversionUtil.toTable(MLEnvironment session,
DataStream<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataStream to Table with specified colNames and colTypes.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.