スパークストリーミングで複数のアクションを並列/非同期で実行

Question

スパークストリーミングで複数のアクションを非同期/並列実行する方法はありますか？ここで が私のコードです：

positions.foreachRDD(rdd -> { 

      JavaRDD<A> pbv = rdd.map(p -> A.create(p));   
      javaFunctions(pbv).writerBuilder("poc", "table_a", mapToRow(A.class)).saveToCassandra();  

      JavaRDD<D> pbd = rdd.map(p -> D.create(p));   
      javaFunctions(pbd).writerBuilder("poc", "table_d", mapToRow(D.class)).saveToCassandra();    

      JavaRDD<L> pblv = rdd.map(p -> L.create(p));   
      javaFunctions(pblv).writerBuilder("poc", "table_l", mapToRow(L.class)).saveToCassandra();    

      JavaRDD<V> pbld = rdd.map(p -> V.create(p));   
      javaFunctions(pbld).writerBuilder("poc", "table_v", mapToRow(V.class)).saveToCassandra(); 

    }); 

私は並列にsaveToCassandraアクションをやりたい、これは「テクニクスの火付け役」または唯一の自作スレッド/実行者扱い経由で可能ですか？

ありがとうございました！

よろしく、 マルクス

Answer 1

massgさんのコメント@は、おそらくフォークのこの種への最速の方法ですが、あなたは、あなたがより簡単にちょうどストリームを分割することにより、これを行うことができることをしたくない場合。

すべてのこれらの要求が並行して起こりますDSTREAMに作用することにより、

positions.map(A.create(p)).saveToCassandra 
positions.map(D.create(p)).saveToCassandra 
positions.map(L.create(p)).saveToCassandra 
positions.map(V.create(p)).saveToCassandra 

ような何か。