public class StringSchemaFactory extends Object implements PulsarSchemaFactory<String>
StringSchema
.Constructor and Description |
---|
StringSchemaFactory() |
Modifier and Type | Method and Description |
---|---|
org.apache.pulsar.client.api.Schema<String> |
createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
Create the schema by the given info.
|
TypeInformation<String> |
createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info)
Create the flink type information by the given schema info.
|
org.apache.pulsar.common.schema.SchemaType |
type()
The supported schema type for this factory.
|
public org.apache.pulsar.common.schema.SchemaType type()
PulsarSchemaFactory
type
in interface PulsarSchemaFactory<String>
public org.apache.pulsar.client.api.Schema<String> createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
PulsarSchemaFactory
createSchema
in interface PulsarSchemaFactory<String>
public TypeInformation<String> createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info)
PulsarSchemaFactory
createTypeInfo
in interface PulsarSchemaFactory<String>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.