apache-flink

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.

5calore

1risposta

Grado di parallelismo in Apache Flink

Posso impostare un grado diverso di parallelismo per diverse parti dell'attività nel nostro programma in Flink? Ad esempio, in che modo Flink interpreta il seguente codice di esempio? I due operatori

8calore

1risposta

Ordinamento globale in Apache Flink

Il metodo sortPartition di un set di dati ordina il set di dati localmente in base ad alcuni campi specificati. Come posso ottenere il mio grande Dataset ordinato globalmente in modo efficiente in Fli

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

7calore

1risposta

Come posso avviare l'interfaccia web di Gestione lavori Flink quando si esegue Flink da un IDE

Vorrei accedere all'interfaccia Web di Flink quando lo avvio localmente dall'IDE. Ho bisogno di questo perché mi piacerebbe accedere ai contatori (accumulatori) di Flink.

7calore

2risposta

Kafka -> Flink DataStream -> MongoDB

Voglio configurare Flink in modo che possa trasformare e reindirizzare i flussi di dati da Apache Kafka a MongoDB. A scopo di test sto costruendo in cima all'esempio flink-streaming-connectors.kafka (

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.