public long getDrainMonitorPollIntervalMillis() {
    return getLong(DRAIN_MONITOR_POLL_INTERVAL_MILLIS, DRAIN_MONITOR_POLL_INTERVAL_MILLIS_DEFAULT);
  }
Get coordinatorStreamFactory according to the configs
@return the name of coordinatorStreamFactory
samza-core/src/main/java/org/apache/samza/config/JobConfig.java