Skip to main content

Module buffers

Module buffers 

Source
Expand description

事件缓冲区模块 - 用于有序模式下的事件排序和批次处理

提供多种缓冲策略:

  • SlotBuffer: 按 slot 缓冲,支持 Ordered 和 StreamingOrdered 模式
  • MicroBatchBuffer: 微秒级时间窗口批次,用于 MicroBatch 模式

Structs§

MicroBatchBuffer
微批次缓冲区,用于 MicroBatch 模式
SlotBuffer
Slot 缓冲区,用于有序模式下缓存同一 slot 的事件