flink-streaming

8calore

1risposta

Ci sono molte domande che mettono a confronto Flink vs Spark Streaming, Flink vs Storm e Storm vs Heron. L'origine di questa domanda deriva dal fatto che sia Apache Flink che Twitter Heron sono veri f

7calore

1risposta

Ottenere elementi JSON da un web con Apache Flink

Dopo aver letto diverse pagine di documentazione di Apache Flink (official documentation, dataartisans), così come gli esempi forniti nel official repository, continuo a vedere esempi in cui usano com

6calore

1risposta

In che modo Apache Flink implementa le iterazioni?

DAG (grafico aciclico diretto) esecuzione di big data è comune. Mi chiedo come Apache Flink implementa le iterazioni. Perché può essere un grafico ciclico.

7calore

3risposta

non è stato in grado di trovare il valore implicito per parametro evidence di tipo org.apache.flink.api.common.typeinfo.TypeInformation [...]

Sto cercando di scrivere alcuni casi d'uso per Apache Flink. Un errore a cui mi imbatto abbastanza spesso è could not find implicit value for evidence parameter of type org.apache.flink.api.common.typ

9calore

1risposta

Ordinamento finestre per lo streaming degli eventi Flink streaming

Sto riscontrando alcuni problemi a comprendere la semantica attorno alla finestra temporale degli eventi. Il seguente programma genera alcune tuple con i timestamp che vengono utilizzati come tempo de

13calore

1risposta

Flink Streaming: come generare un flusso di dati su diverse uscite a seconda dei dati?

In Apache Flink ho un flusso di tuple. Supponiamo che sia davvero semplice Tuple1<String>. La tupla può avere un valore arbitrario nel suo campo valore (ad esempio "P1", "P2", ecc.). L'insieme di valo

10calore

1risposta

Come contare le parole uniche in un flusso?

C'è un modo per contare il numero di parole uniche in un flusso con Flink Streaming? I risultati sarebbero un flusso di numeri che continua ad aumentare.

83calore

2risposta

Quali sono/sono le principali differenze tra Flink e Storm?

Flink è stato compared to Spark, che, a mio avviso, è il confronto errato perché confronta un sistema di elaborazione degli eventi a finestre con il micro-batching; Allo stesso modo, non ha molto sens