Uses of Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema (Flink : Formats : Avro confluent registry 1.20.2-cp1 API)

Packages that use ConfluentRegistryAvroDeserializationSchema
Package Description

org.apache.flink.formats.avro.registry.confluent

Uses of ConfluentRegistryAvroDeserializationSchema in org.apache.flink.formats.avro.registry.confluent

Methods in org.apache.flink.formats.avro.registry.confluent that return ConfluentRegistryAvroDeserializationSchema
Modifier and Type	Method	Description
`static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord>`	ConfluentRegistryAvroDeserializationSchema.`forGeneric(org.apache.avro.Schema schema, String url)`	Creates `ConfluentRegistryAvroDeserializationSchema` that produces `GenericRecord` using the provided reader schema and looks up the writer schema in the Confluent Schema Registry.
`static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord>`	ConfluentRegistryAvroDeserializationSchema.`forGeneric(org.apache.avro.Schema schema, String url, int identityMapCapacity)`	Creates `ConfluentRegistryAvroDeserializationSchema` that produces `GenericRecord` using the provided reader schema and looks up the writer schema in the Confluent Schema Registry.
`static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord>`	ConfluentRegistryAvroDeserializationSchema.`forGeneric(org.apache.avro.Schema schema, String url, int identityMapCapacity, Map<String,?> registryConfigs)`	Creates `ConfluentRegistryAvroDeserializationSchema` that produces `GenericRecord` using the provided reader schema and looks up the writer schema in the Confluent Schema Registry.
`static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord>`	ConfluentRegistryAvroDeserializationSchema.`forGeneric(org.apache.avro.Schema schema, String url, Map<String,?> registryConfigs)`	Creates `ConfluentRegistryAvroDeserializationSchema` that produces `GenericRecord` using the provided reader schema and looks up the writer schema in the Confluent Schema Registry.
`static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T>`	ConfluentRegistryAvroDeserializationSchema.`forSpecific(Class<T> tClass, String url)`	Creates `AvroDeserializationSchema` that produces classes that were generated from Avro schema and looks up the writer schema in the Confluent Schema Registry.
`static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T>`	ConfluentRegistryAvroDeserializationSchema.`forSpecific(Class<T> tClass, String url, int identityMapCapacity)`	Creates `AvroDeserializationSchema` that produces classes that were generated from Avro schema and looks up the writer schema in the Confluent Schema Registry.
`static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T>`	ConfluentRegistryAvroDeserializationSchema.`forSpecific(Class<T> tClass, String url, int identityMapCapacity, Map<String,?> registryConfigs)`	Creates `AvroDeserializationSchema` that produces classes that were generated from Avro schema and looks up the writer schema in the Confluent Schema Registry.
`static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T>`	ConfluentRegistryAvroDeserializationSchema.`forSpecific(Class<T> tClass, String url, Map<String,?> registryConfigs)`	Creates `AvroDeserializationSchema` that produces classes that were generated from Avro schema and looks up the writer schema in the Confluent Schema Registry.