public class FlinkTopology extends Object
FlinkTopology
translates a TopologyBuilder
to a Flink program.
CAUTION: StateSpout
s are currently not supported.Modifier and Type | Method and Description |
---|---|
static FlinkTopology |
createTopology(org.apache.storm.topology.TopologyBuilder stormBuilder)
Creates a Flink program that uses the specified spouts and bolts.
|
JobExecutionResult |
execute()
Directly executes the Storm topology based on the current context (local when in IDE and
remote when executed through ./bin/flink).
|
StreamExecutionEnvironment |
getExecutionEnvironment()
Returns the underlying Flink
StreamExecutionEnvironment for the Storm topology. |
org.apache.storm.generated.StormTopology |
getStormTopology() |
public static FlinkTopology createTopology(org.apache.storm.topology.TopologyBuilder stormBuilder)
stormBuilder
- The Storm topology builder to use for creating the Flink topology.FlinkTopology
which contains the translated Storm topology and may be executed.public StreamExecutionEnvironment getExecutionEnvironment()
StreamExecutionEnvironment
for the Storm topology.public JobExecutionResult execute() throws Exception
JobExecutionResult
after the execution of the Storm topology.Exception
- which occurs during execution of the translated Storm topology.public org.apache.storm.generated.StormTopology getStormTopology()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.