public class FlinkSubmitter extends Object
FlinkSubmitter
mimics a StormSubmitter
to submit Storm topologies to a Flink cluster.Modifier and Type | Class and Description |
---|---|
static interface |
FlinkSubmitter.FlinkProgressListener
Dummy interface use to track progress of file upload.
|
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
logger |
Constructor and Description |
---|
FlinkSubmitter() |
Modifier and Type | Method and Description |
---|---|
static String |
submitJar(Map conf,
String localJar)
In Flink, jar files are submitted directly when a program is started.
|
static String |
submitJar(String localJar)
In Flink, jar files are submitted directly when a program is started.
|
static void |
submitTopology(String name,
Map<?,?> stormConf,
FlinkTopology topology,
org.apache.storm.generated.SubmitOptions opts)
Submits a topology to run on the cluster.
|
static void |
submitTopology(String name,
Map stormConf,
FlinkTopology topology)
Submits a topology to run on the cluster.
|
static void |
submitTopologyWithProgressBar(String name,
Map<?,?> stormConf,
FlinkTopology topology)
|
public static void submitTopology(String name, Map<?,?> stormConf, FlinkTopology topology, org.apache.storm.generated.SubmitOptions opts) throws org.apache.storm.generated.AlreadyAliveException, org.apache.storm.generated.InvalidTopologyException
name
- the name of the storm.stormConf
- the topology-specific configuration. See Config
.topology
- the processing to execute.opts
- to manipulate the starting of the topology.org.apache.storm.generated.AlreadyAliveException
- if a topology with this name is already runningorg.apache.storm.generated.InvalidTopologyException
- if an invalid topology was submittedpublic static void submitTopology(String name, Map stormConf, FlinkTopology topology) throws org.apache.storm.generated.AlreadyAliveException, org.apache.storm.generated.InvalidTopologyException
FlinkSubmitter.FlinkProgressListener
is ignored because progress bars are not supported by Flink.name
- the name of the storm.stormConf
- the topology-specific configuration. See Config
.topology
- the processing to execute.org.apache.storm.generated.AlreadyAliveException
- if a topology with this name is already runningorg.apache.storm.generated.InvalidTopologyException
- if an invalid topology was submittedpublic static void submitTopologyWithProgressBar(String name, Map<?,?> stormConf, FlinkTopology topology) throws org.apache.storm.generated.AlreadyAliveException, org.apache.storm.generated.InvalidTopologyException
submitTopology(String, Map, FlinkTopology, SubmitOptions)
. Progress bars are not supported by
Flink.name
- the name of the storm.stormConf
- the topology-specific configuration. See Config
.topology
- the processing to execute.org.apache.storm.generated.AlreadyAliveException
- if a topology with this name is already runningorg.apache.storm.generated.InvalidTopologyException
- if an invalid topology was submittedpublic static String submitJar(Map conf, String localJar)
conf
- the topology-specific configuration. See Config
.localJar
- file path of the jar file to submitpublic static String submitJar(String localJar)
localJar
- file path of the jar file to submitCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.