實(shí)現(xiàn)一個(gè)購買商品后,對(duì)數(shù)據(jù)進(jìn)行處理統(tǒng)計(jì)的功能.

將購買的商品信息保存在Orders類中

public class Orders {private String name;private double price;private int amount;public Orders(String name, double price, int amount) {this.name = name;this.price = price;this.amount = amount;}public String getName() {return name;}public void setName(String name) {this.name = name;}public double getPrice() {return price;}public void setPrice(double price) {this.price = price;}public int getAmount() {return amount;}public void setAmount(int amount) {this.amount = amount;}

通過map()處理數(shù)據(jù),輸出購買每一件商品的總價(jià)

public static void main(String[] args) {List<Orders> list = new ArrayList<>();list.add(new Orders("dq csdn", 60.00, 80));list.add(new Orders("dq android", 100.20, 73));list.add(new Orders("dq java", 72.02, 15));//計(jì)算購買每一件商品的總價(jià)list.stream().map((x) -> x.getAmount() * x.getPrice()).forEach(System.out::println);}

通過reduce()對(duì)map()處理后的數(shù)據(jù)進(jìn)行統(tǒng)計(jì)

double all = list.stream().map((x) -> x.getAmount() * x.getPrice()).reduce((x, y) -> x + y).get();System.out.println(String.format("%.2f", all));

使用DoubleStream接口中DoubleSummaryStatistics類進(jìn)行數(shù)據(jù)統(tǒng)計(jì)

DoubleSummaryStatistics statistics=list.stream().mapToDouble((x)->x.getAmount()* x.getPrice()).summaryStatistics();System.out.println("商品品種"+statistics.getCount()+"商品總花費(fèi)"+statistics.getSum()+"商品平均花費(fèi)"+statistics.getAverage()+"最高花費(fèi)"+statistics.getMax()+"最低花費(fèi)"+statistics.getMin());

總代碼:

import java.util.ArrayList; import java.util.DoubleSummaryStatistics; import java.util.List;public class Orders {private String name;private double price;private int amount;public Orders(String name, double price, int amount) {this.name = name;this.price = price;this.amount = amount;}public String getName() {return name;}public void setName(String name) {this.name = name;}public double getPrice() {return price;}public void setPrice(double price) {this.price = price;}public int getAmount() {return amount;}public void setAmount(int amount) {this.amount = amount;}public static void main(String[] args) {List<Orders> list = new ArrayList<>();list.add(new Orders("dq csdn", 60.00, 80));list.add(new Orders("dq android", 100.20, 73));list.add(new Orders("dq java", 72.02, 15));DoubleSummaryStatistics statistics=list.stream().mapToDouble((x)->x.getAmount()* x.getPrice()).summaryStatistics();System.out.println("商品品種"+statistics.getCount()+"商品總花費(fèi)"+statistics.getSum()+"商品平均花費(fèi)"+statistics.getAverage()+"最高花費(fèi)"+statistics.getMax()+"最低花費(fèi)"+statistics.getMin());} }

參考<<第一行代碼>>第13章

總結(jié)

以上是生活随笔為你收集整理的Java Stream MapReduce大数据开发模型的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。