Hi, the blog post uses Flinks wrapper for Hadoop InputFormats. This has been ported to the new API and is described in the documentation.
So you just need to take Mongos Hadoop IF and plug it into the new IF wrapper. :-) Fabian Am Dienstag, 4. November 2014 schrieb Flavio Pompermaier : > Hi to all, > > I saw this post > https://flink.incubator.apache.org/news/2014/01/28/querying_mongodb.html > but it use the old APIs (HadoopDataSource instead of DataSource). > How can I use Mongodb with the new Flink APIs? > > Best, > Flavio >
