Package | Description |
---|---|
org.apache.flink.api.java |
Constructor and Description |
---|
ScalaShellRemoteEnvironment(String host,
int port,
FlinkILoop flinkILoop,
Configuration clientConfig,
String... jarFiles)
Creates new ScalaShellRemoteEnvironment that has a reference to the FlinkILoop
|
ScalaShellRemoteStreamEnvironment(String host,
int port,
FlinkILoop flinkILoop,
Configuration configuration,
String... jarFiles)
Creates a new RemoteStreamEnvironment that points to the master
(JobManager) described by the given host name and port.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.