org.elasticsearch.hadoop.handler.impl.elasticsearch

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 java.lang.Object
implements EventConverter<E>

Base implementation for converting failure events into ECS documents

Constructor Summary

Constructors

Constructor and Description
BaseEventConverter(java.lang.String eventType, java.lang.String eventMessage)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.hadoop.util.ecs.ElasticCommonSchema.TemplateBuilder	configureTemplate(org.elasticsearch.hadoop.util.ecs.ElasticCommonSchema.TemplateBuilder templateBuilder) Perform some logic against the template builder in order to inject values before the template is built.
org.elasticsearch.hadoop.util.BytesArray	generateEvent(E event, org.elasticsearch.hadoop.util.ecs.MessageTemplate template) Converts an event into an ECS compliant document using the given message template.
abstract java.lang.String	getRawEvent(E event) Visible for testing
java.lang.String	getTimestamp(E event) Visible for testing
java.lang.String	renderEventMessage(E event) Visible for testing
java.lang.String	renderExceptionMessage(E event) Visible for testing
java.lang.String	renderExceptionType(E event) Visible for testing

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseEventConverter

public BaseEventConverter(java.lang.String eventType,
                          java.lang.String eventMessage)

Method Detail

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 java.io.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:

java.io.IOException

getTimestamp

public java.lang.String getTimestamp(E event)

Visible for testing

renderEventMessage

public java.lang.String renderEventMessage(E event)

Visible for testing

renderExceptionType

public java.lang.String renderExceptionType(E event)

Visible for testing

renderExceptionMessage

public java.lang.String renderExceptionMessage(E event)

Visible for testing

getRawEvent

public abstract java.lang.String getRawEvent(E event)
                                      throws java.io.IOException

Visible for testing

Throws:

java.io.IOException