Spark pour les débutants: Tutoriels – Connexion à Cassandra

English English

Bienvenue, nous allons découvrir dans ce tutoriel comment connecter Spark avec base de données Cassandra en utilisant le langage Java. Le code sera fait en Java, vous trouverez les liens de Gist Github pendant du tutoriel.

Video Demo

Installation DataStax distribution d’Apache Cassandra

Téléchargez et installez DataStax Community Edition v2.1.1 64 bits ou choisir une autre version.

Ajout de dépendances Cassandra

Pour utiliser Cassandra avec Spark Apache Cassandra nous avons besoin Connecteur pour Spark.

Nous allons d’abord créer un nouveau projet Maven avec Eclipse, pour cet exemple, je vais créer une petite application de gestion des produits. Je choisis tn.esprit  comme groupe Id et cassandra   comme Artefact Id.

On va changer le pom.xml en ajoutant des dépendances. Et nous allons spécifier la version Java 1.8 pour le compilateur Maven.

Créer CassConnector (classe java) qui se connecte à la base de données de cassandra, et nous allons créer un nouveau keyspace et l’utiliser.

Exécution et test avec shell Cassandra CQL

Pour exécuter notre application, nous devons d’abord générer avec Manven en exécutant maven install et clic droit sur le fichier CassConnector.java et Exécuter en tant que application Java.

Maintenant, testez la création de nouvelles keyspace avec shell Cassandra CQL