風暴三叉戟批次是否同時處理？

Question

我想知道三叉戟批次是否並行執行，即多批次可以同時運行？

除此之外，我還有幾個問題太小而無法單獨發佈。如果它們足夠大，可以隨意發表評論以單獨發佈。

1. 如果什麼樣的處理只在一批特定的元組失敗？

   然後批次將被重放，導致成功先前處理的元組的再處理？例如，單詞計數，其中每個元組包含一個單詞但只有幾個元組被成功計數？例如，如果有三個字叫人，並且計數只顯示2，這意味着一個元組在處理中失敗？

2. 在僅此tutorial，以前TxID添加存儲。以前的交易ID是什麼？

   例如，有三個批1,2,3,4。現在，批次＃1，＃2被執行並且批次＃1被重放。然後txid將是2，因爲最近處理的批次是批次＃2，並且無法識別是否先前處理了批次1。 如果是這樣，那麼批次必須按順序執行。這意味着直到批次＃1成功完成批次＃2不能執行。如果是這種情況，那麼執行批處理的並行性在哪裏？

3. 如果僅僅是不適合的拓撲批量正確執行什麼特殊功能？

   例如，我有兩個功能，一個是堅持該消息到數據庫，另一個是產生到卡夫卡隊列。在這裏，堅持數據庫是成功的，但是由於一些節點故障（例如說），推向卡夫卡隊列失敗。然後，我只想要推送到該特定批次的卡夫卡隊列的功能。三叉戟有辦法嗎？爲此，我將不僅需要存儲txid，還需要存儲要爲該txid處理的函數列表。它怎麼能做到？

Answer 1

，盡我的理解：

1. 任何失敗被認爲是失敗的批次，而這將通過管口重播。事務狀態存儲上次操作的值和事務標識。如果計數「man」失敗，那麼它的txid將小於當前的txid，並且應該將這批數據添加到存儲的值中。否則，它可以忽略重播，因爲它知道此批次的數據已經計入了該密鑰。

2. 國與國之間的交易均嚴格TxID添加順序進行處理，而只能由有狀態的組件。函數可以在即將到來的事務元組上執行。

3. 這聽起來像你想要的國家，而不是功能。該州將記住它已經完成批處理，並在重播時忽略它。