Package | Description |
---|---|
org.apache.flink.storm.api |
Class and Description |
---|
FlinkClient
FlinkClient mimics a Storm NimbusClient and Nimbus .Client at once, to interact with
Flink's JobManager instead of Storm's Nimbus. |
FlinkLocalCluster
FlinkLocalCluster mimics a Storm LocalCluster . |
FlinkLocalCluster.LocalClusterFactory
A factory that creates local clusters.
|
FlinkTopology
FlinkTopology translates a TopologyBuilder to a Flink program. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.