Skip to main content

wrap_flow_region_watermark_stream

datanode::region_server

Function wrap_flow_region_watermark_stream 

Source 
fn wrap_flow_region_watermark_stream(
    stream: SendableRecordBatchStream,
    region_id: RegionId,
    query_ctx: &QueryContextRef,
) -> SendableRecordBatchStream