is_parallelized_backfill_enabled_cdc_scan_fragment

risingwave_meta::stream::cdc

Function is_parallelized_backfill_enabled_cdc_scan_fragment 

Source 
pub(crate) fn is_parallelized_backfill_enabled_cdc_scan_fragment(
    fragment_type_mask: FragmentTypeMask,
    nodes: &StreamNode,
) -> Option<&StreamCdcScanNode>
Expand description

Returns some cdc scan node if the fragment is CDC scan and has parallelized backfill enabled.