Hey Arnaud!
I have made a quick sample implementation of how you can very efficiently
support generic keys, like yours. I put the code in this repository:
https://github.com/StephanEwen/flink-generic-keys
It implements a special key selector. You can use that to do what you used
to do, and it in
Hi Giacomo,
a DataSet is just a logical construct to define data flows. It does not
actually hold any data.
Here's a code snippet that sums some Integers and returns the result to the
client program:
DataSet data = ...
// sum
DataSet sum = data.reduce(new ReduceFunction() {
public Integer red
Hi Fabian,
is possible to assign the reduce result to a POJO variable?
At the moment inside the reduce function I'm passing the final count to a
global variable.
Example:
double X = DataSet myDataSet.GroupReduce(new MyReducer());
On Tue, Apr 28, 2015 at 9:54 PM, Fabian Hueske wrote:
> You can a
