Load files using SQLLoad from Apache KafkaAggregate data with rollupWrite an ingestion specTransform input dataConvert ingestion spec to SQL