Function mz_storage::source::responsible_for

source · 
pub fn responsible_for<P: Hashable>(
    _source_id: &GlobalId,
    worker_id: usize,
    worker_count: usize,
    pid: P
) -> bool
Expand description

Returns true if the given source id/worker id is responsible for handling the given partition.