Migrates the Druid-loading job for wmf.edit_hourly dataset. Modifies the HiveToDruidOperator to include some parameters needed for this job (map_memory). Also, some adjustments are needed to support snapshot-based partitioning.
Migrates the Druid-loading job for wmf.edit_hourly dataset. Modifies the HiveToDruidOperator to include some parameters needed for this job (map_memory). Also, some adjustments are needed to support snapshot-based partitioning.