0
Ich kann Mysql-Datenbank in Fall pf JdbcRDD und DataFrames verbinden. Aber, wie man Verbindung von MySQL-Datenbank im Spark-streaming herstellt?Wie stelle ich die Verbindung der MySQL-Datenbank in Spark-Streaming her?
Vielen Dank.
Vielen Dank für Ihre Antwort. In benutzerdefinierten Empfängerlogik habe ich Datenbankverbindung erstellt, aber ich bin verwirrt, in welcher Form (jdbcrdd oder DF) kann ich die Tabelle abrufen, so dass ich dies in Spark-Streaming verwenden kann? Grundsätzlich muss ich zwischen zwei Tabellen in Spark verbinden. –
Nun, das ist Ihre Geschäftsanforderung, Sie können Ihren benutzerdefinierten Empfänger nach Ihren Bedürfnissen ändern. Behalten Sie die Best Practices im Hinterkopf und schreiben Sie nicht den gesamten Code in den Receiver selbst :) –