cluster-computing - Spark Streaming 计算作业划分为不同的节点

Question

假设我们的集群中有 20 个节点。operation1是统计1s时间窗的字数，operation2是对operation1在60s时间窗上的结果求和（结果当然是60s时间窗上的字数）。但是有什么方法可以指定节点 1-10 执行操作 1，节点 11-20 执行操作 2？谢谢！