Moving Average Funken

Ich habe Echtzeit-Streaming-Daten kommen in Funken und ich möchte eine gleitende durchschnittliche Prognose auf die Zeitreihe Daten zu tun. Gibt es eine Möglichkeit, dies zu implementieren mit Funken in Java Ive bereits erwähnt. Gist. githubsamklr27411098f04fc46dcd05revisions und Apache Spark Moving Average, aber beide diese Codes sind in Scala geschrieben. Da bin ich nicht vertraut mit Scala, Im nicht in der Lage zu beurteilen, wenn Ill finde es nützlich oder sogar konvertieren den Code in Java. Gibt es eine direkte Umsetzung der Prognose in Spark Java am 12. August 15 um 12: 44Moving Durchschnitt ist ein heikles Problem für Spark, und jedes verteilte System. Wenn die Daten über mehrere Computer verteilt werden, gibt es einige Zeitfenster, die Partitionen kreuzen. Wir müssen die Daten zu Beginn der Partitionen duplizieren, sodass die Berechnung des gleitenden Durchschnitts pro Partition eine vollständige Abdeckung ergibt. Hier ist ein Weg, dies zu tun in Spark. Die Beispieldaten: Ein einfacher Partitionierer, der jede Zeile in die Partition einfügt, die wir durch den Schlüssel spezifizieren: Erstellen Sie die Daten mit dem ersten Fenster - 1 Zeilen, die auf die vorherige Partition kopiert wurden: Berechnen Sie den gleitenden Durchschnitt auf jeder Partition: Wegen der doppelten Segmente Wird dies keine Lücken in der Abdeckung. Real-Time After Hours Pre-Market News Flash Zitat Zusammenfassung Zitat Interaktive Charts Standardeinstellung Bitte beachten Sie, dass, sobald Sie Ihre Auswahl treffen, gilt es für alle zukünftigen Besuche der NASDAQ gelten. Wenn Sie zu einem beliebigen Zeitpunkt daran interessiert sind, auf die Standardeinstellungen zurückzukehren, wählen Sie bitte die Standardeinstellung oben. Wenn Sie Fragen haben oder Probleme beim Ändern Ihrer Standardeinstellungen haben, senden Sie bitte eine E-Mail an isfeedbacknasdaq. Bitte bestätigen Sie Ihre Auswahl: Sie haben ausgewählt, Ihre Standardeinstellung für die Angebotssuche zu ändern. Dies ist nun Ihre Standardzielseite, wenn Sie Ihre Konfiguration nicht erneut ändern oder Cookies löschen. Sind Sie sicher, dass Sie Ihre Einstellungen ändern möchten, haben wir einen Gefallen zu bitten Bitte deaktivieren Sie Ihren Anzeigenblocker (oder aktualisieren Sie Ihre Einstellungen, um sicherzustellen, dass Javascript und Cookies aktiviert sind), damit wir Sie weiterhin mit den erstklassigen Marktnachrichten versorgen können Und Daten, die Sie von uns erwarten.