Java Spark DStreams, как рассчитать среднее значение пары ключ-значение - PullRequest
Новая
       43

Java Spark DStreams, как рассчитать среднее значение пары ключ-значение

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

У меня есть данные JSON, как показано ниже 

"symbol": "xxxx",
        "timestamp": "2018-09-11 13:37:00",
        "priceData": {
            "open": "266.8200",
            "high": "266.8700",
            "low": "266.7800",
            "close": "266.8543",
            "volume": "1604"
        }

Я использовал JSONObject и JSONAarray для анализа этих данных и получил значение ключевого значения, например 

(XXXX,345.55) (YYYY,889.4) (XXXX,340.00)(YYYY,888.5)

Теперь я хочу вычислить среднеецена закрытия.Как мне этого добиться с помощью JAVA DSTREAM Transformations?

...