apache-spark - スパーク ストリーミングのオブジェクトが特定のノードで実行されるようにする

Question

次のような Spark ストリーミング設定があるとします。

JavaReceiverInputDStream<...> rndLists = jssc.receiverStream(new JavaRandomReceiver(...));

rndLists.map(new NeuralNetMapper(...))
    .foreach(new JavaSyncBarrier(...));

たとえば、 JavaRandomReceiver と JavaSyncBarrier が同じノードに配布されるようにする方法はありますか? それとも、これは理にかなった質問ですか?

スパークストリーミングがクラスター全体でどのように機能するかについての情報も大歓迎です。