This pipeline is designed to ingest streaming data from Kafka and load a trained ML model in Scala custom processor to predict sentiment of tweets. The pipeline runs on Databricks cluster and stores the tweets along with its score in Delta Lake.
Be the first to reply!
Reply
Enter your E-mail address. We'll send you an e-mail with instructions to reset your password.