@Override public StorageHandlerInfo getStorageHandlerInfo(Table table) throws MetaException {
    if (DruidKafkaUtils.isKafkaStreamingTable(table)) {
      KafkaSupervisorReport kafkaSupervisorReport = fetchKafkaSupervisorReport(table);
      if (kafkaSupervisorReport == null) {
        return DruidStorageHandlerInfo.UNREACHABLE;
      }
      return new DruidStorageHandlerInfo(kafkaSupervisorReport);
    } else {
      // Currently we do not expose any runtime info for non-streaming tables.
      // In future extend this add more information regarding table status.
      // e.g. Total size of segments in druid, load status of table on historical nodes etc.
      return null;
    }
  }
This function checks the load status of Druid segments by polling druid coordinator.
@param segments List of druid segments to check for
druid-handler/src/java/org/apache/hadoop/hive/druid/DruidStorageHandler.java