flume

5calore

2risposta

Recupero del timestamp dalla riga di hbase

Utilizzando l'API Hbase (Get/Put) o l'API HBQL, è possibile recuperare il timestamp di una colonna specifica?

16calore

1risposta

Può essere questa domanda è stato chiesto prima, ma penso che è bene considerare anche oggi dato che queste tecnologie hanno maturato. Stiamo cercando di utilizzare uno dei flume, Kafka, scriba, o alt

7calore

2risposta

Registrazione distribuita con canale

Dispongo di un servizio mobile distribuito su 7 server, ciascuno dei quali svolge un compito specifico. Voglio registrare le informazioni da loro e in seguito ricavarne informazioni di business. L'ho

5calore

2risposta

Usa flume per lo streaming di dati su S3

Sto provando il flume per qualcosa di molto semplice, in cui vorrei spingere il contenuto dei miei file di registro su S3. Sono stato in grado di creare un agente flume che avrebbe letto il contenuto

7calore

2risposta

Apache flume twitter agent non streaming dei dati

Sto provando a trasmettere i feed di Twitter a hdf e quindi utilizzare l'hive. Ma la prima parte, lo streaming dei dati e il caricamento su hdf non funziona e si ottiene Null Pointer Exception. Questo

9calore

2risposta

Trasferimento di file da nodo remoto a HDFS con Flume

Ho un sacco di file binari compressi in formato * gz. Questi sono generati su un nodo remoto e devono essere trasferiti su HDFS che si trova su uno dei server del datacenter. Sto esplorando l'opzione

6calore

2risposta

Flume non scrive su HDFS a meno che non venga ucciso

Ho seguito il link per l'impostazione di sink di TwitterSource e HDFS. comando usato per avviare l'agente: bin/flume-ng agent -n TwitterAgent -c conf -f conf/flume-conf.properties -Dflume.root.logger=

9calore

4risposta

Come installare e configurare il flusso di Apache?

Sono nuovo nel canale Apache. Devo installare il flume in cima all'ambiente cluster HDFS. L'ho fatto a Google, tutto sta dicendo usando la distribuzione cloudera ma ho bisogno di installare e configur

5calore

2risposta

Sink personalizzato per evento null Flume-ng

Sto provando a scrivere un sink personalizzato per flume-ng. Ho esaminato i sink e la documentazione esistenti e l'ho codificato. Tuttavia, il metodo 'process()' che dovrebbe ricevere gli eventi finis