code: def _FlushEvents(self):
      
      try:
        # pylint: disable=unexpected-keyword-arg
        # pylint does not recognizes request_timeout as a valid kwarg. According
        # to http://elasticsearch-py.readthedocs.io/en/master/api.html#timeout
        # it should be supported.
        self._client.bulk(
            body=self._event_documents, doc_type=self._document_type,
            index=self._index_name, request_timeout=self._DEFAULT_REQUEST_TIMEOUT)
  
      except ValueError as exception:
        # Ignore problematic events
        logger.warning('Unable to bulk insert with error: {0!s}'.format(
            exception))
  
      logger.debug('Inserted {0:d} events into Elasticsearch'.format(
          self._number_of_buffered_events))
  
      self._event_documents = []
      self._number_of_buffered_events = 0
docs: Inserts the buffered event documents into Elasticsearch.