This module contains multiple versions of a simple Word-Count example to illustrate the usage of the compatibility layer:
the usage of spouts and bolts within a regular Flink streaming program (ie, embedded mode)
SpoutSourceWordCountuses a spout as data source within a Flink streaming program
BoltTokenizeerWordCountuses a bolt to split sentences into words within a Flink streaming program
Tupleinput type and accesses attributes by field names (rather than index)
BoltTokenizeerWordCountPOJOused POJO input type and accesses attributes by field names (rather than index)
how to submit a whole Storm topology to Flink 3.
WordCountTopologyplugs a Storm topology together *
StormWordCountLocalsubmits the topology to a local Flink cluster (similar to a
LocalClusterin Storm) (
WordCountLocalByNameaccesses attributes by field names rather than index) *
WordCountRemoteByClientsubmits the topology to a remote Flink cluster (similar to the usage of
NimbusClientin Storm) *
WordCountRemoteBySubmittersubmits the topology to a remote Flink cluster (similar to the usage of
Additionally, this module package the three example Word-Count programs as jar files to be submitted to a Flink cluster via
bin/flink run example.jar.
(Valid jars are
org.apache.flink.storm.wordcount.operators contains original spouts and bolts that can be used unmodified within Storm or Flink.