Package | Description |
---|---|
org.apache.flink.formats.avro.registry.confluent |
Modifier and Type | Method and Description |
---|---|
static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> |
ConfluentRegistryAvroDeserializationSchema.forGeneric(org.apache.avro.Schema schema,
String url)
Creates
ConfluentRegistryAvroDeserializationSchema that produces GenericRecord
using provided reader schema and looks up writer schema in 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 provided reader schema and looks up writer schema in Confluent Schema Registry. |
static <T extends org.apache.avro.specific.SpecificRecord> |
ConfluentRegistryAvroDeserializationSchema.forSpecific(Class<T> tClass,
String url)
Creates
AvroDeserializationSchema that produces classes that were generated from avro
schema and looks up writer schema in Confluent Schema Registry. |
static <T extends org.apache.avro.specific.SpecificRecord> |
ConfluentRegistryAvroDeserializationSchema.forSpecific(Class<T> tClass,
String url,
int identityMapCapacity)
Creates
AvroDeserializationSchema that produces classes that were generated from avro
schema and looks up writer schema in Confluent Schema Registry. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.