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

Class JsonSerdeUtil

java.lang.Object

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

@Internal
public class JsonSerdeUtil
extends Object

A 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.ObjectReader	createObjectReader(SerdeContext serdeContext)
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter	createObjectWriter(SerdeContext 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.

createObjectReader

public static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader createObjectReader(SerdeContext serdeContext)

createObjectWriter

public static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectWriter createObjectWriter(SerdeContext serdeContext)