Interface | Description |
---|---|
FlinkLocalCluster.LocalClusterFactory |
A factory that creates local clusters.
|
FlinkSubmitter.FlinkProgressListener |
Dummy interface use to track progress of file upload.
|
Class | 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.DefaultLocalClusterFactory |
A factory that instantiates a FlinkLocalCluster.
|
FlinkSubmitter |
FlinkSubmitter mimics a StormSubmitter to submit Storm topologies to a Flink cluster. |
FlinkTopology |
FlinkTopology translates a TopologyBuilder to a Flink program. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.