Now that we have the data to be used to train and predict in place, we will develop the Trident topology using the Trident-ML library.
Again, we will create a Maven project to implement our topology. The following are the steps to create this project:
Create a new Maven project with the
com.learningstorm
group ID and theml
artifact ID.Add the following dependencies for Kafka in the
pom.xml
file:<!-- Dependency for Storm --> <dependency> <groupId>storm</groupId> <artifactId>storm-core</artifactId> <version>0.9.0.1</version> <scope>provided</scope> </dependency> <!-- Dependency for Storm-Kafka spout --> <dependency> <groupId>net.wurstmeister.storm</groupId> <artifactId>storm-kafka-0.8-plus</artifactId> <version>0.4.0</version> </dependency> <!-- Dependency for Trident-ML --> <dependency>...