Tenho dados de transmissão em tempo real que entram em faísca e eu gostaria de fazer uma previsão média móvel sobre esses dados de séries temporais. Existe alguma maneira de implementar isso usando uma faísca em Java Ive já mencionada. Gist. githubsamklr27411098f04fc46dcd05revisões e Apache Spark Moving Average, mas ambos esses códigos estão escritos em Scala. Como não estou familiarizado com Scala, não consigo julgar se eu acho útil ou até mesmo converter o código para Java. Existe alguma implementação direta de previsão em Spark Java perguntou 12 de agosto 15 em 12: 44 A média de migração é um problema complicado para Spark e qualquer sistema distribuído. Quando os dados estão espalhados por várias máquinas, haverá janelas de tempo que cruzam partições. Temos que duplicar os dados no início das partições, para que o cálculo da média móvel por partição dê uma cobertura completa. Aqui está uma maneira de fazer isso na Spark. Os dados de exemplo: um particionador simples que coloca cada linha na partição que especificamos pela chave: Crie os dados com a primeira janela - 1 linha copiada para a partição anterior: basta calcular a média móvel em cada partição: devido aos segmentos duplicados Isso não terá lacunas na cobertura.
O par de moedas USDCHF é muitas vezes chamado de The Swissie. O franco suíço é o último franco ainda em emissão na Europa. CHF é uma abreviatura de Confoederatio Helvetica Franc, e representa a economia da situação da nação neutra no centro da Europa. A Suíça tem sido um centro bancário fundamental para clientes em todo o mundo, e o segredo com o qual eles mantêm suas operações bancárias tornou-os um dos locais mais desejáveis para armazenar dinheiro. Isso ajudou a trazer força considerável para o franco suiço. Pressionando exportadores da nação. Quando a crise da dívida europeia envolveu o continente, os influxos maciços em francos suíços pioraram a situação até que o Banco Nacional Suíço (SNB) criou uma pegada ao euro a uma taxa de 1,2 francos suíços por cada 1 euro. Se o par de moedas EURCHF caiu abaixo de 1.20, o SNB propôs vender CHF e comprar EUR para suportar o piso 1.20. USDCHF USDCHF Primeiro teste de força da média de 200 dias é agora por Jamie Saettele, CMT por Jamie Saett...
Comments
Post a Comment