значит для JavaPairDStream в потоковой передаче искры - PullRequest
Новая
       34

значит для JavaPairDStream в потоковой передаче искры

0 голосов
/ 13 сентября 2018

Прежде всего, я новичок в Spark Streaming и мне нужна помощь.У меня есть JavaPairDStream, как показано ниже, содержащий StockName (например, Yahoo) и его цену закрытия (например, 8500.00).

Он имеет несколько ключей, таких как Yahoo, Google, Microsoft и цена закрытия.Теперь мне нужно узнать среднюю цену закрытия для каждой акции (например, Yahoo, Google и т. Д.).Каков наилучший способ достичь этого?Может ли кто-нибудь помочь мне найти решение?

Примечание: StockData - это пользовательский класс, который я создал для этого.

** JavaPairDStream pairDStream = events.mapToPair (new PairFunction () {

            @Override
            public Tuple2<String, Double> call(StockData stockData) throws Exception
            {
                return new Tuple2<String, Double>(stockData.getStockName(), stockData.getClosingPrice());
            }
            });**
...