Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

How do I transfer my cassandra data to pyspark using QueryCassandra and ExecutePySpark Nifi Processors?

How do I transfer my cassandra data to pyspark using QueryCassandra and ExecutePySpark Nifi Processors?

New Contributor

62912-pyspark.png

I'm just querying cassandra table using querycassandra processor but what I'm not understanding is how do I pass my Json output file into ExecutePyspark processor as a Input file and later on I need to pass my Spark output data to Hive. Please help me on this, Thanks


cassandra.png
Don't have an account?
Coming from Hortonworks? Activate your account here