Apache Spark est un moteur de traitement de données distribué open source écrit en Scala fournissant une API unifiée et des ensembles de données distribués aux utilisateurs pour le traitement par lots et en continu. Les cas d'utilisation d'Apache Spark sont souvent liés à l'apprentissage automatique / profond, au traitement des graphiques.
Je recherche la solution pour ajouter la valeur d'horodatage de kafka à mon schéma de streaming structuré Spark. J'ai extrait le champ de valeur de kafka et j'ai cré&ea ...
J'ai une table externe sur le bucket gs et pour faire une logique de compactage, je veux déterminer le chemin complet sur lequel la table est créée. val tableName="stock_ ...
Si j'utilise spark-submit pour soumettre deux applications Spark, la 2ème application échoue toujours avec une erreur comme ci-dessous. Caused by: java.lang.IllegalStateExceptio ...
