Functionality to ingest a Druid segment and change the schema

Add druidFirehose - can be used to reIndex filtered data from a datasource
let's test with different lengths and also with empty firehoses