Cole Lechleiter

[Draft] Add supervisor to ingest from published segments

1

### Description Reduce the delay to be able to query compacted/reindexed data by implementing a "druid" type supervisor. The supervisor creates realtime tasks which read druid segments (already-published and potentially...

The objective is for ingestion tasks to produce segments which can contain finalized aggregations. This can eliminate the need for a an extra step (a query to produce finalized aggregations)...