Package | Description |
---|---|
org.apache.flink.ml.common | |
org.apache.flink.table.api.java |
Modifier and Type | Method and Description |
---|---|
BatchTableEnvironment |
MLEnvironment.getBatchTableEnvironment()
Get the BatchTableEnvironment.
|
Constructor and Description |
---|
MLEnvironment(ExecutionEnvironment batchEnv,
BatchTableEnvironment batchTableEnv)
Construct with the batch environment and the the batch table environment given by user.
|
MLEnvironment(ExecutionEnvironment batchEnv,
BatchTableEnvironment batchTableEnv,
StreamExecutionEnvironment streamEnv,
StreamTableEnvironment streamTableEnv)
Construct with env given by user.
|
Modifier and Type | Method and Description |
---|---|
static BatchTableEnvironment |
BatchTableEnvironment.create(ExecutionEnvironment executionEnvironment)
|
static BatchTableEnvironment |
BatchTableEnvironment.create(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.