risingwave_stream::executor::source

Module fs_source_executor

source
๐Ÿ‘ŽDeprecated: will be replaced by new fs source (list + fetch)

Structsยง

Constantsยง

  • WAIT_BARRIER_MULTIPLE_TIMES ๐Ÿ”’ Deprecated
    A constant to multiply when calculating the maximum time to wait for a barrier. This is due to some latencies in network and cost in meta.