risingwave_frontend::handler::create_sink

Function get_partition_compute_info

source
pub async fn get_partition_compute_info(
    with_options: &WithOptionsSecResolved,
) -> Result<Option<PartitionComputeInfo>, RwError>