apache-flink

7calore

1risposta

Ingresso compresso BZip2 per Apache Flink

Ho un dump di wikipedia compresso con bzip2 (scaricato da http://dumps.wikimedia.org/enwiki/), ma non voglio decomprimerlo: voglio elaborarlo durante la decompressione al volo. So che è possibile farl

10calore

1risposta

Flink Scala API "non abbastanza argomenti"

sto avendo problemi usando Apache Flink Scala API Per esempio, anche quando prendo gli esempi dalla documentazione ufficiale, il compilatore Scala mi dà tonnellate di errori di compilazione. Codice: o

23calore

1risposta

Apache Flink vs Apache Spark come piattaforme per l'apprendimento automatico su larga scala?

Qualcuno potrebbe confrontare Flink e Spark come piattaforme per l'apprendimento automatico? Quale è potenzialmente migliore per gli algoritmi iterativi? Collegamento alla discussione generale Flink v

7calore

2risposta

In che modo Apache Flink è paragonabile a Mapreduce su Hadoop?

In che modo Apache Flink è paragonabile a Mapreduce su Hadoop? In che modo è migliore e perché?

198calore

6risposta

Qual è la differenza tra Apache Spark e Apache Flink?

Quali sono le differenze tra Apache Spark e Apache Flink? Apache Flink sostituire Hadoop?

5calore

1risposta

comportamento Iterator in Flink reduceGroup

Io sono la creazione di un sistema che dovrebbe gestire enormi quantità di dati e ho bisogno di capire come il ridurre operatore di gruppo funziona Ho un insieme di dati in cui applico un groupby e, s