org.wikimedia.eventutilities.flink.formats.json

Class JsonRowSerializationSchema.Builder

java.lang.Object

org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder

Enclosing class:

JsonRowSerializationSchema

@PublicEvolving
public static final class JsonRowSerializationSchema.Builder
extends Object

Builder for JsonRowSerializationSchema.

Method Summary

Modifier and Type	Method and Description
JsonRowSerializationSchema	build() Finalizes the configuration and checks validity.
JsonRowSerializationSchema.Builder	withNormalizationFunction(Function<Consumer<com.fasterxml.jackson.databind.node.ObjectNode>,com.fasterxml.jackson.databind.node.ObjectNode> normalization) The normalization function to apply on the provided event data.
JsonRowSerializationSchema.Builder	withObjectMapper(com.fasterxml.jackson.databind.ObjectMapper mapper)
JsonRowSerializationSchema.Builder	withoutNormalization() Do not apply any normalization to serialized events.
JsonRowSerializationSchema.Builder	withTypeInfo(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo) Sets type information for JSON serialization schema.

Methods inherited from class java.lang.Object

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

Method Detail

withTypeInfo

public JsonRowSerializationSchema.Builder withTypeInfo(@Nonnull
                                                       org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo)

Sets type information for JSON serialization schema.

Parameters:

typeInfo - Type information describing the result type. The field names of Row are used to parse the JSON properties.

withNormalizationFunction

public JsonRowSerializationSchema.Builder withNormalizationFunction(Function<Consumer<com.fasterxml.jackson.databind.node.ObjectNode>,com.fasterxml.jackson.databind.node.ObjectNode> normalization)

The normalization function to apply on the provided event data.

withoutNormalization

public JsonRowSerializationSchema.Builder withoutNormalization()

Do not apply any normalization to serialized events. Should never be used for producing events to the WMF Event Platform.

withObjectMapper

public JsonRowSerializationSchema.Builder withObjectMapper(com.fasterxml.jackson.databind.ObjectMapper mapper)

build

public JsonRowSerializationSchema build()

Finalizes the configuration and checks validity.

Returns:

Configured JsonRowSerializationSchema