HI Matthias, Where do you put the code for the Storm compatibility? Under streams module directory?
- Henry On Thu, Apr 2, 2015 at 10:31 AM, Matthias J. Sax <mj...@informatik.hu-berlin.de> wrote: > Hi @all, > > I started to work on an compatibility layer to run Storm Topologies on > Flink. I just pushed a first beta: > https://github.com/mjsax/flink/tree/flink-storm-compatibility > > Please check it out, and let me know how you like it. In this first > version, I tried to code without changing too many things in the > existing code. However, a deeper integration would be nice. > > There are many things that do not work yet. Currently, only shuffle and > fieldsGrouping is supported (and only Storm's default output stream). > Furthermore, topologies must be "simple", ie, they cannot be configured > with a Config object and Storm meta information (ie, TopologyContext) is > also not there. > > The layer can be used to integrate existing Spouts and/or Bolts as Flink > operators into a regular Flink program. Furthermore, a whole Storm > topology can be executed by switching from TopologyBuilder to > FlinkTopologyBuilder and from LocalCluster/NimbusClient/StormSubmitter > to FlinkLocalCluster/FlinkClient/FlinkStormSubmitter. > > Examples of both cases are given as ITCases. > > > Cheers, > Matthias > >
