code: def SetFlushInterval(self, flush_interval):
      
      self._flush_interval = flush_interval
      logger.debug('Elasticsearch flush interval: {0:d}'.format(flush_interval))
docs: Set the flush interval.
  
      Args:
        flush_interval (int): number of events to buffer before doing a bulk
            insert.