1 單個microbatch總是一個RDD。它不依賴於接收器的數量。 要確保特定的批次訂購,您可以使用stream.transform(_.someMethodThatSortsRDD)。 來源 2016-12-02 02:09:56 +0 如果出現呃逆和延遲,該怎麼辦?在下次調用時可能不會有2個RDDS? – thebluephantom +0 它不會發生。批次總是按順序處理。如果還在進行中,則不會有來自同一個流的其他批次啓動。 – 2016-12-02 13:34:17
如果出現呃逆和延遲,該怎麼辦?在下次調用時可能不會有2個RDDS? – thebluephantom
它不會發生。批次總是按順序處理。如果還在進行中,則不會有來自同一個流的其他批次啓動。 – 2016-12-02 13:34:17