org.wikimedia.eventutilities.core.event

Class EventKeySelector

java.lang.Object

org.wikimedia.eventutilities.core.event.EventKeySelector

All Implemented Interfaces:

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

public class EventKeySelector
extends Object
implements UnaryOperator<com.fasterxml.jackson.databind.node.ObjectNode>, Serializable

Creates a key node by extracting aliased fields from a value node.

Keep in mind that the key is used for hashing, so make sure the order of key fields is stable.

See Also:

Producer Requirements/Producer Libraries, Serialized Form

Constructor Summary

Constructors

Constructor and Description
EventKeySelector(List<Map.Entry<String,String>> namedAliasPaths)

Method Summary

Modifier and Type	Method and Description
com.fasterxml.jackson.databind.node.ObjectNode	apply(com.fasterxml.jackson.databind.node.ObjectNode valueNode)
static EventKeySelector	createFromMessageKeyFields(com.fasterxml.jackson.databind.JsonNode messageKeyFields)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.UnaryOperator

identity

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Detail

EventKeySelector

public EventKeySelector(List<Map.Entry<String,String>> namedAliasPaths)

Method Detail

apply

public com.fasterxml.jackson.databind.node.ObjectNode apply(com.fasterxml.jackson.databind.node.ObjectNode valueNode)

Specified by:

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

createFromMessageKeyFields

public static EventKeySelector createFromMessageKeyFields(com.fasterxml.jackson.databind.JsonNode messageKeyFields)