如何为Java RDD的每个元素读取和保存数据库的通知限制

I am new to Apache Spark. I am writing a program in which I create a JavaRDD by fetching data from Apache Cassandra database. Then I process each element in RDD by invoking some helper methods which are not part of my driver program. I am new to Apache Spark. I am writing a progra