title: Can we make the different transformation functions for the Spark Streaming running on different servers?
body: <pre><code>val words = lines.flatMap(_.split(" "))
  val pairs = words.map(word =&gt; (word, 1))
  </code></pre>
  
  <p>For the above example, we know there are two transformation functions. Both of them must running at the same process\server, however I want to make the second transformation running on a different server from the first one to achieve scalability, is it possible?</p>