org.apache.flink.table.planner.plan.nodes.exec.serde

Class JsonSerdeUtil

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.serde.JsonSerdeUtil

public class JsonSerdeUtil
extends Object

An utility class that provide abilities for JSON serialization and deserialization.

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper	createObjectMapper(SerdeContext serdeCtx) Create an ObjectMapper which DeserializationContext wraps a SerdeContext.
static boolean	hasJsonCreatorAnnotation(Class<?> clazz) Return true if the given class's constructors have @JsonCreator annotation, else false.

Methods inherited from class java.lang.Object

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

Method Detail

hasJsonCreatorAnnotation

public static boolean hasJsonCreatorAnnotation(Class<?> clazz)

Return true if the given class's constructors have @JsonCreator annotation, else false.

createObjectMapper

public static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper createObjectMapper(SerdeContext serdeCtx)

Create an ObjectMapper which DeserializationContext wraps a SerdeContext.