org.apache.flink.statefun.flink.core.common

Class PolyglotUtil

java.lang.Object

org.apache.flink.statefun.flink.core.common.PolyglotUtil

public final class PolyglotUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static <M extends com.google.protobuf.Message> M	parseProtobufOrThrow(com.google.protobuf.Parser<M> parser, java.io.InputStream input)
static Address	polyglotAddressToSdkAddress(Address address)
static Address	sdkAddressToPolyglotAddress(Address sdkAddress)

Methods inherited from class java.lang.Object

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

Method Detail

parseProtobufOrThrow

public static <M extends com.google.protobuf.Message> M parseProtobufOrThrow(com.google.protobuf.Parser<M> parser,
                                                                             java.io.InputStream input)

sdkAddressToPolyglotAddress

public static Address sdkAddressToPolyglotAddress(Address sdkAddress)

polyglotAddressToSdkAddress

public static Address polyglotAddressToSdkAddress(Address address)