org.apache.flink.ml.common

Class MLEnvironment

java.lang.Object

org.apache.flink.ml.common.MLEnvironment

public class MLEnvironment
extends Object

The MLEnvironment stores the necessary context in Flink. Each MLEnvironment will be associated with a unique ID. The operations associated with the same MLEnvironment ID will share the same Flink job context.

Both MLEnvironment ID and MLEnvironment can only be retrieved from MLEnvironmentFactory.

See Also:

ExecutionEnvironment, StreamExecutionEnvironment, BatchTableEnvironment, StreamTableEnvironment

Constructor Summary

Constructors

Constructor and Description
MLEnvironment() Construct with null that the class can load the environment in the `get` method.
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.
MLEnvironment(StreamExecutionEnvironment streamEnv, StreamTableEnvironment streamTableEnv) Construct with the stream environment and the the stream table environment given by user.

Method Summary

Modifier and Type	Method and Description
BatchTableEnvironment	getBatchTableEnvironment() Get the BatchTableEnvironment.
ExecutionEnvironment	getExecutionEnvironment() Get the ExecutionEnvironment.
StreamExecutionEnvironment	getStreamExecutionEnvironment() Get the StreamExecutionEnvironment.
StreamTableEnvironment	getStreamTableEnvironment() Get the StreamTableEnvironment.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MLEnvironment

public MLEnvironment()

Construct with null that the class can load the environment in the `get` method.

MLEnvironment

public MLEnvironment(ExecutionEnvironment batchEnv,
                     BatchTableEnvironment batchTableEnv)

Construct with the batch environment and the the batch table environment given by user.

The env can be null which will be loaded in the `get` method.

Parameters:

batchEnv - the ExecutionEnvironment

batchTableEnv - the BatchTableEnvironment

MLEnvironment

public MLEnvironment(StreamExecutionEnvironment streamEnv,
                     StreamTableEnvironment streamTableEnv)

Construct with the stream environment and the the stream table environment given by user.

The env can be null which will be loaded in the `get` method.

Parameters:

streamEnv - the StreamExecutionEnvironment

streamTableEnv - the StreamTableEnvironment

MLEnvironment

public MLEnvironment(ExecutionEnvironment batchEnv,
                     BatchTableEnvironment batchTableEnv,
                     StreamExecutionEnvironment streamEnv,
                     StreamTableEnvironment streamTableEnv)

Construct with env given by user.

The env can be null which will be loaded in the `get` method.

Parameters:

batchEnv - the ExecutionEnvironment

batchTableEnv - the BatchTableEnvironment

streamEnv - the StreamExecutionEnvironment

streamTableEnv - the StreamTableEnvironment

Method Detail

getExecutionEnvironment

public ExecutionEnvironment getExecutionEnvironment()

Get the ExecutionEnvironment. if the ExecutionEnvironment has not been set, it initial the ExecutionEnvironment with default Configuration.

Returns:

the batch ExecutionEnvironment

getStreamExecutionEnvironment

public StreamExecutionEnvironment getStreamExecutionEnvironment()

Get the StreamExecutionEnvironment. if the StreamExecutionEnvironment has not been set, it initial the StreamExecutionEnvironment with default Configuration.

Returns:

the StreamExecutionEnvironment

getBatchTableEnvironment

public BatchTableEnvironment getBatchTableEnvironment()

Get the BatchTableEnvironment. if the BatchTableEnvironment has not been set, it initial the BatchTableEnvironment with default Configuration.

Returns:

the BatchTableEnvironment

getStreamTableEnvironment

public StreamTableEnvironment getStreamTableEnvironment()

Get the StreamTableEnvironment. if the StreamTableEnvironment has not been set, it initial the StreamTableEnvironment with default Configuration.

Returns:

the StreamTableEnvironment