flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hagersaleh <loveallah1...@yahoo.com>
Subject why when use orders.aggregate(Aggregations.MAX, 2) not return one value but return more value
Date Wed, 08 Jul 2015 00:00:48 GMT
why when use orders.aggregate(Aggregations.MAX, 2) not return one value but
return more value

 ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();    
 DataSet<Orders> orders=(DataSet<Orders>)
env.readCsvFile("/home/hadoop/Desktop/Dataset/orders.csv")
      .fieldDelimiter('|')
      .includeFields(mask).ignoreFirstLine()
      .tupleType(get_Order().getClass());
       orders.aggregate(Aggregations.MAX, 2)  ;

orders.print();    
        
orders.writeAsCsv("/home/hadoop/Desktop/Dataset/join_instead_of_optmization",
"\n", "|",WriteMode.OVERWRITE);
         env.execute();

out put
1> (280866,129457,96048.38)
1> (280867,16568,89875.17)
1> (280868,47827,118013.89)
1> (280869,104143,220415.76)
1> (280870,105512,262166.76)
1> (280871,36244,123478.83)
1> (280896,148177,92956.99)
1> (280897,83611,128889.07)
1> (280898,29863,289893.15)
1> (280899,143962,111581.46)
1> (280900,43577,26781.38)
1> (280901,87340,30915.09)
1> (280902,6769,235803.72)
1> (280903,61471,138553.46)
1> (280928,69407,168763.3)
1> (280929,114457,5392.93)
1> (280930,58939,47427.22)
1> (280931,110210,125524.13)
1> (280932,91751,11434.53)



--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/why-when-use-orders-aggregate-Aggregations-MAX-2-not-return-one-value-but-return-more-value-tp1977.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message