org.apache.flink.statefun.flink.common.types

Class TypedValueUtil

java.lang.Object

org.apache.flink.statefun.flink.common.types.TypedValueUtil

public final class TypedValueUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static boolean	isProtobufTypeOf(TypedValue typedValue, com.google.protobuf.Descriptors.Descriptor messageDescriptor)
static TypedValue	packProtobufMessage(com.google.protobuf.Message protobufMessage)
static <PB extends com.google.protobuf.Message> PB	unpackProtobufMessage(TypedValue typedValue, com.google.protobuf.Parser<PB> protobufMessageParser)

Methods inherited from class java.lang.Object

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

Method Detail

isProtobufTypeOf

public static boolean isProtobufTypeOf(TypedValue typedValue,
                                       com.google.protobuf.Descriptors.Descriptor messageDescriptor)

packProtobufMessage

public static TypedValue packProtobufMessage(com.google.protobuf.Message protobufMessage)

unpackProtobufMessage

public static <PB extends com.google.protobuf.Message> PB unpackProtobufMessage(TypedValue typedValue,
                                                                                com.google.protobuf.Parser<PB> protobufMessageParser)