def _ExportEvent(self, output_module, event, deduplicate_events=True):
    if event.timestamp != self._export_event_timestamp:
      self._FlushExportBuffer(
          output_module, deduplicate_events=deduplicate_events)
      self._export_event_timestamp = event.timestamp
    self._export_event_heap.PushEvent(event)