Class BaseEventConverter<E extends Exceptional>

java.lang.Object
org.elasticsearch.hadoop.handler.impl.elasticsearch.BaseEventConverter<E>
All Implemented Interfaces:
EventConverter<E>

public abstract class BaseEventConverter<E extends Exceptional> extends Object implements EventConverter<E>
Base implementation for converting failure events into ECS documents
  • Constructor Details

    • BaseEventConverter

      public BaseEventConverter(String eventType, String eventMessage)
  • Method Details

    • configureTemplate

      public org.elasticsearch.hadoop.util.ecs.ElasticCommonSchema.TemplateBuilder configureTemplate(org.elasticsearch.hadoop.util.ecs.ElasticCommonSchema.TemplateBuilder templateBuilder)
      Description copied from interface: EventConverter
      Perform some logic against the template builder in order to inject values before the template is built.
      Specified by:
      configureTemplate in interface EventConverter<E extends Exceptional>
    • generateEvent

      public org.elasticsearch.hadoop.util.BytesArray generateEvent(E event, org.elasticsearch.hadoop.util.ecs.MessageTemplate template) throws IOException
      Description copied from interface: EventConverter
      Converts an event into an ECS compliant document using the given message template.
      Specified by:
      generateEvent in interface EventConverter<E extends Exceptional>
      Parameters:
      event - Exceptional event to convert
      template - template to use for conversion
      Returns:
      BytesArray containing the document data
      Throws:
      IOException
    • getTimestamp

      public String getTimestamp(E event)
      Visible for testing
    • renderEventMessage

      public String renderEventMessage(E event)
      Visible for testing
    • renderExceptionType

      public String renderExceptionType(E event)
      Visible for testing
    • renderExceptionMessage

      public String renderExceptionMessage(E event)
      Visible for testing
    • getRawEvent

      public abstract String getRawEvent(E event) throws IOException
      Visible for testing
      Throws:
      IOException