get_op_consistency_level

risingwave_stream::executor::mview::materialize

Function get_op_consistency_level 

Source 
fn get_op_consistency_level(
    conflict_behavior: ConflictBehavior,
    may_have_downstream: bool,
    subscriber_ids: &HashSet<SubscriberId>,
) -> StateTableOpConsistencyLevel