Hi Lydia,
I tried to reproduce your problem but I couldn't. Can it be that you have
somewhere a non deterministic operation in your program or do you read the
data from a source with varying data? Maybe you could send us a compilable
and complete program which reproduces your problem.
Cheers,
Till
On Tue, Mar 22, 2016 at 2:21 PM, Lydia Ickler <ickle...@googlemail.com>
wrote:
> Hi all,
>
> I have a question.
> If I have a DataSet DataSet<Tuple3<Integer, Integer, Double>> ds and I
> want to normalize all values (at position 2) in it by the maximum of the
> DataSet (ds.aggregate(Aggregations.MAX, 2)).
> How do I tackle that?
>
> If I use the cross operator my result changes every time I run the program
> (see code below)
> Any suggestions?
>
> Thanks in advance!
> Lydia
>
> ds.cross(ds.aggregate(Aggregations.MAX, 2)).map(new normalizeByMax());
>
> public static final class normalizeByMax implements
> MapFunction<Tuple2<Tuple3<Integer, Integer, Double>, Tuple3<Integer,
> Integer, Double>>,
> Tuple3<Integer, Integer, Double>> {
>
> public Tuple3<Integer, Integer, Double> map(
> Tuple2<Tuple3<Integer, Integer, Double>, Tuple3<Integer, Integer,
> Double>> value)
> throws Exception {
> return new Tuple3<Integer, Integer,
> Double>(value.f0.f0,value.f0.f1,value.f0.f2/value.f1.f2);
> }
> }
>
>
>
>
