2016-12-02 79 views

回答

1
  • 單個microbatch總是一個RDD。它不依賴於接收器的數量。
  • 要確保特定的批次訂購,您可以使用stream.transform(_.someMethodThatSortsRDD)
+0

如果出現呃逆和延遲,該怎麼辦?在下次調用時可能不會有2個RDDS? – thebluephantom

+0

它不會發生。批次總是按順序處理。如果還在進行中,則不會有來自同一個流的其他批次啓動。 – 2016-12-02 13:34:17