Module refill

This module contains the refill flow task, which is used to refill flow with given table id and a time range.

Modules

• test_send 🔒

Structs

• RefillTask
  Task to refill flow with given table id and a time range
• TaskData 🔒

Enums

• QueryStream 🔒
  Query stream of RefillTask, simply wrap RecordBatches and RecordBatchStream and check output is not AffectedRows
• TaskState 🔒
  Refill task state