spark-streaming

2Hitze

1Antwort

Ich habe eine pojo Klasse von emp wie unten: ich in der Lage bin Streaming-Daten zu lesen und ich möchte Daten an Hbase @JsonInclude(Include.NON_NULL) public class empData implements Serializable {

0Hitze

1Antwort

NPE, wenn ich versuche Funken zu tun Streaming mit Twitter

Ich bin neu in SparkStreaming, wenn versucht, die Funken Twitter Streaming-Job zu übergeben, die folgende Störung erhalten: Lost task 0.0 in stage 0.0 (TID 0,sandbox.hortonworks.com):java.lang.NullPoi

2Hitze

1Antwort

mapWithState(). Timeout() um eine Funktion auszulösen

Ich möchte die mapWithState().timeout() Funktion als ein Ereignis verwenden, um eine andere Funktion auszulösen. Gibt es einen Weg dazu? Ich habe über einige statesnapshot() gelesen, um nach timeout L

1Hitze

1Antwort

kafka Weitstrahl DSTREAM Karte nicht gedruckt

Ich habe diese einfache Kafka-Stream val messages = KafkaUtils.createDirectStream[String, String, StringDecoder, StringDecoder](ssc, kafkaParams, topicsSet) // Each Kafka message is a flight val fl

1Hitze

1Antwort

Spark-Streaming - KafkaWordCount nicht auf einem Spark-Standalone-Cluster laufen kann

ich Ihre Hilfe und Beratung benötigen für Apache Spark KafkaWordCount Beispiel auf einem eigenständigen Funken Cluster ausgeführt: I Beispiel Zündkerzen laufen kann, KafkaWordCount, im lokalen Modus d

0Hitze

1Antwort

Spark Streaming für Fitbit-Daten

Ich mache Fitbit Oauth 2.0, um auf Fitbit-Daten zuzugreifen. Ich speichere diese Daten in SQL db, nach denen ich Spark SQL verwenden, um die Daten zu analysieren. Wenn ich Spark Streaming verwenden mu

0Hitze

1Antwort

Zählen mit Spark Streaming

Ich habe ein Programm in Spark Streaming, das eingehende Dateien in HDFS erkennt, was ich tun möchte, ist jede Datei analysieren und testen das Vorhandensein von zwei Wörtern in jeder Datei, und an je

3Hitze

2Antwort

Cassandra + Spark für Echtzeitanalyse

Ich arbeite an einer Anwendung für "Echtzeit-Rendering von Big Data (Spatial Data)". Mit Hilfe von Spark Streaming + Spark SQL + WebSocket kann ich vordefinierte Abfragen im Dashboard rendern. Aber ic

-2Hitze

1Antwort

Einzelner Knoten Standalone Spark?

Gibt es eine Möglichkeit, Spark ohne Hadoop/HDFS auf einem einzelnen Knoten zu installieren und zu verwenden? Ich möchte nur ein paar einfache Beispiele ausprobieren und möchte es so leicht wie möglic

3Hitze

2Antwort

Handle verschiedene Zustände

Ich fragte mich, ob es möglich war, verschiedene Zustände in einer Anwendung radikal zu erhalten? Zum Beispiel, haben die update function des ersten Zustandes den einen aus dem zweiten Zustand? Ich er