chore: reword comment on late_arrive_window_seconds for clarity
parent
2854b54420
commit
6f2d20cb19
|
@ -147,9 +147,10 @@ pub struct LifecycleRules {
|
||||||
/// After how many transactions should IOx write a new checkpoint?
|
/// After how many transactions should IOx write a new checkpoint?
|
||||||
pub catalog_transactions_until_checkpoint: NonZeroU64,
|
pub catalog_transactions_until_checkpoint: NonZeroU64,
|
||||||
|
|
||||||
/// Writers will generally have this amount of time to send late arriving writes
|
/// Once a partition hasn't received a write for this period of time,
|
||||||
/// or this could be their clock skew. Once a partition hasn't recieved a write
|
/// it will be compacted and, if set, persisted. Writers will generally
|
||||||
/// for this period of time, it will be compacted and, if set, persisted.
|
/// have this amount of time to send late arriving writes or this could
|
||||||
|
/// be their clock skew.
|
||||||
pub late_arrive_window_seconds: NonZeroU32,
|
pub late_arrive_window_seconds: NonZeroU32,
|
||||||
|
|
||||||
/// Maximum number of rows before triggering persistence
|
/// Maximum number of rows before triggering persistence
|
||||||
|
|
|
@ -64,9 +64,10 @@ message LifecycleRules {
|
||||||
// If 0 / absent, this default to 100.
|
// If 0 / absent, this default to 100.
|
||||||
uint64 catalog_transactions_until_checkpoint = 11;
|
uint64 catalog_transactions_until_checkpoint = 11;
|
||||||
|
|
||||||
/// Writers will generally have this amount of time to send late arriving writes
|
/// Once a partition hasn't received a write for this period of time,
|
||||||
/// or this could be their clock skew. Once a partition hasn't recieved a write
|
/// it will be compacted and, if set, persisted. Writers will generally
|
||||||
/// for this period of time, it will be compacted and, if set, persisted.
|
/// have this amount of time to send late arriving writes or this could
|
||||||
|
/// be their clock skew.
|
||||||
uint32 late_arrive_window_seconds = 12;
|
uint32 late_arrive_window_seconds = 12;
|
||||||
|
|
||||||
// Maximum number of rows before triggering persistence
|
// Maximum number of rows before triggering persistence
|
||||||
|
|
|
@ -101,9 +101,10 @@ struct Create {
|
||||||
#[structopt(long, default_value = "100", parse(try_from_str))]
|
#[structopt(long, default_value = "100", parse(try_from_str))]
|
||||||
catalog_transactions_until_checkpoint: NonZeroU64,
|
catalog_transactions_until_checkpoint: NonZeroU64,
|
||||||
|
|
||||||
/// Writers will generally have this amount of time to send late arriving writes
|
/// Once a partition hasn't received a write for this period of time,
|
||||||
/// or this could be their clock skew. Once a partition hasn't recieved a write
|
/// it will be compacted and, if set, persisted. Writers will generally
|
||||||
/// for this period of time, it will be compacted and, if set, persisted.
|
/// have this amount of time to send late arriving writes or this could
|
||||||
|
/// be their clock skew.
|
||||||
#[structopt(long, default_value = "300")]
|
#[structopt(long, default_value = "300")]
|
||||||
late_arrive_window_seconds: u32,
|
late_arrive_window_seconds: u32,
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue