5
C'è qualche API/modo per integrare Spark Streaming con JMS. Sono in grado di integrarmi con Kafka e Sockets ma di integrarmi con la coda o argomento Jms che non riesco a.Spark streaming con JMS - Nessuna API
A
risposta
3
Penso che dovresti provare a chiamare l'API del ricevitore nella scintilla. È necessario creare ricevitore personalizzato
http://spark.apache.org/docs/latest/streaming-custom-receivers.html
Controllare anche contare da das Tathagat che è scintilla collaboratore da
www.apache-spark-user-list.1001560.n3.nabble.com/Spark- Streaming-e-JMS-td5371.html
Se hai bisogno di aiuto in dettaglio fammi sapere
1
so che questo è un vecchio post. Dal momento che sto lavorando su qualcosa di simile. È possibile utilizzare il ricevitore scintilla JMS
Problemi correlati
- 1. Streaming di Spark Streaming Kafka
- 2. Persistendo Spark uscita Streaming
- 3. Spark Streaming UpdateStateByKey
- 4. Spark Streaming stato storico
- 5. Streaming Spark: sicurezza dell'applicazione
- 6. Lettura da Cassandra con Spark Streaming
- 7. Metriche personalizzate di streaming Spark
- 8. Parsing json in spark-streaming
- 9. Funzionamento della finestra Streaming Spark
- 10. Spark Dataset API - join
- 11. Classe KafkaUtils non trovata nello streaming Spark
- 12. scrivibile hadoop NotSerializableException con Apache Spark API
- 13. Spark Streaming groupByKey e updateStateByKey Implementazione
- 14. problemi di affidabilità con Checkpoint/WAL in Spark Streaming 1.6.0
- 15. Spark in streaming viene chiamato updateStateByKey con parametri aggiuntivi
- 16. Streaming di Spark con una tabella di ricerca dinamica
- 17. Come interrompere con garbo un'applicazione Spark Streaming su YARN?
- 18. Spark streaming 1.6.0 - Esecutori che rimbalzano
- 19. Elaborazione in corso in Spark Streaming
- 20. Spark Streaming - elaborazione file di dati binari
- 21. Svantaggi di Spark Streaming in confronto con i sistemi di streaming reale Real
- 22. Accesso a MQ con JMS
- 23. API di streaming Twitter C#
- 24. Come si pubblica un argomento JMS con Spring JMS?
- 25. python-twitter streaming api support/example
- 26. API di streaming di Twitter con Tweepy rifiuta oauth
- 27. Spark streaming di più fonti, ricaricare il dataframe
- 28. Spark Streaming: come aggiornare periodicamente il RDD memorizzato nella cache?
- 29. Websphere MQ come origine dati per Apache Spark Streaming
- 30. BrokerNotAvailableError: Impossibile trovare il leader Eccezione durante lo Spark Streaming
come usare questo ricevitore cliente per ottenere messaggi JMS per esempio come onMessage() metodo-quando un messaggio JMS arriva sarà integrato in questo codice? – vsingh28
Ti invierò il codice di esempio domani –
saresti in grado di inserire il codice di esempio in github? e fornire un collegamento? – user422930