org.wikimedia.eventutilities.core.event

Interface EventNormalizationStep

All Superinterfaces:

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

All Known Implementing Classes:

EventNormalizationStep.Validation

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface EventNormalizationStep
extends Serializable, Consumer<com.fasterxml.jackson.databind.node.ObjectNode>

Define the steps to "normalize" an event before sending it to kafka. Normalize here stands for "standardization" to make outgoing events compliant to the WMF event platform recommendations.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	EventNormalizationStep.Validation

Method Summary

Modifier and Type	Method and Description
static EventNormalizationStep	eventId(Supplier<UUID> uuidSupplier) Set the event if (meta.id) if not already set.
static EventNormalizationStep	eventTime(Instant eventTime) Set the event time (dt) if not already set.
static com.fasterxml.jackson.databind.node.ObjectNode	getOrSetMeta(com.fasterxml.jackson.databind.node.ObjectNode node)
static EventNormalizationStep	ingestionTime(SerializableClock clock) Set the ingestionTime (meta.dt) if not already set.
static EventNormalizationStep	schemaValidation(com.fasterxml.jackson.databind.node.ObjectNode jsonSchema, String schemaUri) Validates the event against the provided schema (must be the last step to apply).
static EventNormalizationStep	streamAndSchema(String streamName, String schemaUri) Forcibly set the stream (meta.stream) and the schema URI.

Methods inherited from interface java.util.function.Consumer

accept, andThen

Method Detail

ingestionTime

static EventNormalizationStep ingestionTime(SerializableClock clock)

Set the ingestionTime (meta.dt) if not already set.

eventTime

static EventNormalizationStep eventTime(Instant eventTime)

Set the event time (dt) if not already set.

eventId

static EventNormalizationStep eventId(Supplier<UUID> uuidSupplier)

Set the event if (meta.id) if not already set.

streamAndSchema

static EventNormalizationStep streamAndSchema(String streamName,
                                              String schemaUri)

Forcibly set the stream (meta.stream) and the schema URI.

schemaValidation

static EventNormalizationStep schemaValidation(com.fasterxml.jackson.databind.node.ObjectNode jsonSchema,
                                               String schemaUri)

Validates the event against the provided schema (must be the last step to apply).

getOrSetMeta

static com.fasterxml.jackson.databind.node.ObjectNode getOrSetMeta(com.fasterxml.jackson.databind.node.ObjectNode node)