dstream

5calore

1risposta

Come trasportare flussi di dati su più intervalli batch in Spark Streaming

Sto utilizzando Apache Spark Streaming 1.6.1 per scrivere un'applicazione Java che unisce due flussi di dati Key/Value e scrive l'output su HDFS. I due flussi di dati contengono stringhe K/V e vengono

apache-spark spark-streaming dstream 2016-05-20

---

6calore

2risposta

Per ciascun RDD in un DStream, come posso convertirlo in un array o qualche altro tipico tipo di dati Java?

Vorrei convertire un DStream in un array, elenco, ecc. Quindi posso quindi tradurlo in json e servirlo su un endpoint. Sto usando la scintilla di apache, iniettando dati di Twitter. Come faccio a pref

scala apache-spark spark-streaming dstream 2014-07-16

---