org.wikimedia.eventutilities.core.event

Interface JsonEventGenerator.EventNormalizer

All Superinterfaces:

Function<Consumer<com.fasterxml.jackson.databind.node.ObjectNode>,com.fasterxml.jackson.databind.node.ObjectNode>, Serializable

Enclosing class:

JsonEventGenerator

public static interface JsonEventGenerator.EventNormalizer
extends Serializable, Function<Consumer<com.fasterxml.jackson.databind.node.ObjectNode>,com.fasterxml.jackson.databind.node.ObjectNode>

A component that applies various normalization and verification steps to the events it receives. This object is serializable and is suited for use with frameworks like spark or flink.

Method Summary

Modifier and Type	Method and Description
default com.fasterxml.jackson.databind.node.ObjectNode	apply(Consumer<com.fasterxml.jackson.databind.node.ObjectNode> eventData)
com.fasterxml.jackson.databind.node.ObjectNode	generateEvent(Consumer<com.fasterxml.jackson.databind.node.ObjectNode> eventData, Instant eventTime)
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper() The object mapper this normalizer will use to generate json nodes.

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Method Detail

generateEvent

com.fasterxml.jackson.databind.node.ObjectNode generateEvent(Consumer<com.fasterxml.jackson.databind.node.ObjectNode> eventData,
                                                             @Nullable
                                                             Instant eventTime)

apply

default com.fasterxml.jackson.databind.node.ObjectNode apply(Consumer<com.fasterxml.jackson.databind.node.ObjectNode> eventData)

Specified by:

apply in interface Function<Consumer<com.fasterxml.jackson.databind.node.ObjectNode>,com.fasterxml.jackson.databind.node.ObjectNode>

getObjectMapper

com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

The object mapper this normalizer will use to generate json nodes.