Доброго дня ...

Честное слово несколько раз читал про stream map collerctors и т.д. ни х не понял как это использовать на казалось бы простом примере ... select org_id,region_id,sum(minPrice),sum(minPrice),sum(bitand(amask,2)/2),sum(bitand(amask,4)/4) from tbl group by org_id,region_id
уже есть заполненный
public static class SOrgPrice {
public Integer ware_id;
public Integer org_id;
public Integer region_id;
public BigDecimal minPrice;
public BigDecimal maxPrice;
public Integer amask;
public Integer getOrg () { return org_id; }
public Integer getRegion () { return region_id; }
public Integer getBitAmask (int bit) { return (amask&bit)/bit; }
public BigDecimal getMinPrice () { return minPrice; }
public BigDecimal getMaxPrice () { return maxPrice; }
}
public ArrayList<SOrgPrice> opData;

Надо заполнить
public static class SOrgSum {
public Integer org_id;
public Integer region_id;
public BigDecimal sumMinPrice;
public BigDecimal sumMaxPrice;
public Integer deliveryCount;
public Integer reservCount;
}
public ArrayList<SOrgSum> opSum;

-----------------------

opSum = (ArrayList)opData.stream().collect(Collectors.groupingBy(SOrgPrice::getOrg,Collectors.groupingBy(SOrgPrice::getRegion)))
.entrySet().stream()
.collect(Collectors.toMap(x -> {
Integer deliveryCount = x.getValue().stream().mapToInt(SOrgPrice::getBitAmask,2).sum();
Integer reserveCount = x.getValue().stream().mapToInt(SOrgPrice::getBitAmask,4).sum();
BigDecimal sumMinPrice = x.getValue().stream().mapToInt(SOrgPrice::getMinPrice).sum();
BigDecimal sumMaxPrice = x.getValue().stream().mapToInt(SOrgPrice::getMaxPrice).sum();
return new SOrgLD(x.getOrg(), x.getRegion(), sumMinPrice, sumMaxPrice, deliveryCount, reserveCount);
}, Map(a -> a.getValue())));
!!!!!!!!!!!!! тут ошибка ... что тут писать? и вообще может где то раньше я ошибся

PS: Переходим с SQL на Java (Ignite) ... все мозги сломал ... как было раньше просто на SQL
select org_id,region_id,sum(minPrice),sum(minPrice),sum(bitand(amask,2)/2),sum(bitand(amask,4)/4) from tbl group by org_id,region_id

Zzz79,

вот что типа того


PS: Раньше в SQL это все решалось временными таблицами, но в Ignite их нет ..
а создавать псевдо-временные и заполнять их уходит ОЧЕНЬ много времени

_Drive_,

Неужели я задал слишком трудный вопрос?

можно проще .. как одним (двумя) операторами java stream реализовать

select F1,F2,sum(f3),min(F4) from PMyTable group by F1,F2;

где PMyTable это

public class SMyTable {
Integer F1;
Integer F2;
Integer F3;
Integer F4;
}
public ArrayList<SMyTable> PMyTable;

PS: как ЭТО сделать через for или foreach более менее понятно