Mover Média Faísca

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. githubsamklr27411098f04fc46dcd05revisions 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 em Java. Existe alguma implementação direta de previsão no Spark Java perguntou 12 de agosto 15 às 12: 44 A média móvel é um problema complicado para a 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: por causa dos segmentos duplicados Isso não terá lacunas na cobertura. Tempo real após horas Informações pré-mercado Citação do resumo das notas citadas Gráficos interativos Configuração padrão Observe que, uma vez que você faça sua seleção, ela se aplicará a todas as visitas futuras ao NASDAQ. Se, a qualquer momento, você estiver interessado em reverter as nossas configurações padrão, selecione Configuração padrão acima. Se você tiver dúvidas ou encontrar quaisquer problemas na alteração das configurações padrão, envie um email para isfeedbacknasdaq. Confirme a sua seleção: Você selecionou para alterar sua configuração padrão para a Pesquisa de orçamento. Esta será a sua página de destino padrão, a menos que você altere sua configuração novamente ou exclua seus cookies. Tem certeza de que deseja alterar suas configurações. Temos um favor a ser solicitado. Desative seu bloqueador de anúncios (ou atualize suas configurações para garantir que o javascript e os cookies estejam habilitados), para que possamos continuar fornecendo as notícias do mercado de primeira linha E os dados que você espera esperar de nós.