Apache Druid

I think we can do we are doing some reingestion using MSQ to reduce size and partitioning we are running these manual jobs to specific set of MM . We can have it in overlord Dynamic config .
``````

```{
    "type": "equalDistributionWithCategorySpec",
    "workerCategorySpec": {
        "categoryMap": {
            "index_kafka": {
                "defaultCategory": "realtime",
                "categoryAffinity": {
                    "datasource1": "ds1_realtime"
                }
            },
            "query_controller": {
                "defaultCategory": "_default_worker_category",
                "categoryAffinity": {
                    "&lt;datasourcenanme&gt;": "rollup"
                }
            },
            "query_worker": {
                "defaultCategory": "_default_worker_category",
                "categoryAffinity": {
                    "&lt;datasourcename&gt;": "rollup"
                }
            }
        },
        "strong": true
    }
}```