@Internal public final class PulsarSchemaUtils extends Object
PulsarSchemaFactory
in this class and
provide the TypeInformation
or PulsarSchema
conversion.Modifier and Type | Field and Description |
---|---|
static String |
CLASS_INFO_PLACEHOLDER |
Modifier and Type | Method and Description |
---|---|
static <T> org.apache.pulsar.client.api.Schema<T> |
createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
Pulsar has a hugh set of built-in schemas.
|
static <T> TypeInformation<T> |
createTypeInformation(org.apache.pulsar.common.schema.SchemaInfo info)
Convert the
SchemaInfo into a flink manageable TypeInformation . |
static <T> Class<T> |
decodeClassInfo(org.apache.pulsar.common.schema.SchemaInfo schemaInfo) |
static org.apache.pulsar.common.schema.SchemaInfo |
encodeClassInfo(org.apache.pulsar.common.schema.SchemaInfo schemaInfo,
Class<?> typeClass) |
static boolean |
haveProtobuf()
A boolean value for determine if user have protobuf-java in his class path.
|
static <T> boolean |
isProtobufTypeClass(Class<T> clazz)
Check if the given class is a protobuf generated class.
|
public static final String CLASS_INFO_PLACEHOLDER
public static boolean haveProtobuf()
public static <T> boolean isProtobufTypeClass(Class<T> clazz)
haveProtobuf()
public static <T> org.apache.pulsar.client.api.Schema<T> createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
SchemaInfo
. This schema info is a wrapped info created by PulsarSchema
.public static <T> TypeInformation<T> createTypeInformation(org.apache.pulsar.common.schema.SchemaInfo info)
SchemaInfo
into a flink manageable TypeInformation
. This schema
info is a wrapped info created by PulsarSchema
.public static org.apache.pulsar.common.schema.SchemaInfo encodeClassInfo(org.apache.pulsar.common.schema.SchemaInfo schemaInfo, Class<?> typeClass)
public static <T> Class<T> decodeClassInfo(org.apache.pulsar.common.schema.SchemaInfo schemaInfo)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.