public class KeyValueSchemaFactory<K,V> extends Object implements PulsarSchemaFactory<org.apache.pulsar.common.schema.KeyValue<K,V>>
KeyValueSchemaImpl
.Constructor and Description |
---|
KeyValueSchemaFactory() |
Modifier and Type | Method and Description |
---|---|
org.apache.pulsar.client.api.Schema<org.apache.pulsar.common.schema.KeyValue<K,V>> |
createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
Create the schema by the given info.
|
TypeInformation<org.apache.pulsar.common.schema.KeyValue<K,V>> |
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<org.apache.pulsar.common.schema.KeyValue<K,V>>
public org.apache.pulsar.client.api.Schema<org.apache.pulsar.common.schema.KeyValue<K,V>> createSchema(org.apache.pulsar.common.schema.SchemaInfo info)
PulsarSchemaFactory
createSchema
in interface PulsarSchemaFactory<org.apache.pulsar.common.schema.KeyValue<K,V>>
public TypeInformation<org.apache.pulsar.common.schema.KeyValue<K,V>> createTypeInfo(org.apache.pulsar.common.schema.SchemaInfo info)
PulsarSchemaFactory
createTypeInfo
in interface PulsarSchemaFactory<org.apache.pulsar.common.schema.KeyValue<K,V>>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.