risingwave_storage::hummock::compactor

Function start_shared_compactor

source 
pub fn start_shared_compactor(
    grpc_proxy_client: GrpcCompactorProxyClient,
    receiver: UnboundedReceiver<Request<DispatchCompactionTaskRequest>>,
    context: CompactorContext,
) -> (JoinHandle<()>, Sender<()>)
Expand description

The background compaction thread that receives compaction tasks from hummock compaction manager and runs compaction tasks.