Package | Description |
---|---|
org.apache.flink.storm.api |
Modifier and Type | Method and Description |
---|---|
static FlinkTopology |
FlinkTopology.createTopology(org.apache.storm.topology.TopologyBuilder stormBuilder)
Creates a Flink program that uses the specified spouts and bolts.
|
Modifier and Type | Method and Description |
---|---|
static void |
FlinkSubmitter.submitTopology(String name,
Map<?,?> stormConf,
FlinkTopology topology,
org.apache.storm.generated.SubmitOptions opts)
Submits a topology to run on the cluster.
|
void |
FlinkLocalCluster.submitTopology(String topologyName,
Map conf,
FlinkTopology topology) |
static void |
FlinkSubmitter.submitTopology(String name,
Map stormConf,
FlinkTopology topology)
Submits a topology to run on the cluster.
|
void |
FlinkClient.submitTopology(String name,
String uploadedJarLocation,
FlinkTopology topology)
Parameter
uploadedJarLocation is actually used to point to the local jar, because Flink does not support
uploading a jar file before hand. |
void |
FlinkLocalCluster.submitTopologyWithOpts(String topologyName,
Map conf,
FlinkTopology topology,
org.apache.storm.generated.SubmitOptions submitOpts) |
void |
FlinkClient.submitTopologyWithOpts(String name,
String uploadedJarLocation,
FlinkTopology topology)
Parameter
uploadedJarLocation is actually used to point to the local jar, because Flink does not support
uploading a jar file before hand. |
static void |
FlinkSubmitter.submitTopologyWithProgressBar(String name,
Map<?,?> stormConf,
FlinkTopology topology)
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.