Hi,
it is not possible to mix the DataSet and DataStream APIs at the moment.
If the DataSet is constant and not too big (which I assume, since otherwise
crossing would be extremely expensive), you can load the data into a
stateful MapFunction.
For that you can implement a RichFlatMapFunction and
We're having trouble mapping our problem to Flink.
- For each incoming item
- Generate tuples of the item crossed with a data set
- Filter the tuples based on a condition
- Know the count of matching tuples
This seems to be mashup of DataStream and DataSet, but it appears you can't
operate with t
