T
- type of record it producespublic class ConfluentRegistryAvroDeserializationSchema<T> extends RegistryAvroDeserializationSchema<T>
SchemaCoder
that uses
Confluent Schema Registry.Modifier and Type | Method and Description |
---|---|
static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> |
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> |
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> |
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> |
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. |
deserialize
forGeneric, forSpecific, getProducedType, isEndOfStream
public static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(org.apache.avro.Schema schema, String url)
ConfluentRegistryAvroDeserializationSchema
that produces GenericRecord
using provided reader schema and looks up writer schema in Confluent Schema Registry.schema
- schema of produced recordsurl
- url of schema registry to connectGenericRecord
public static ConfluentRegistryAvroDeserializationSchema<org.apache.avro.generic.GenericRecord> forGeneric(org.apache.avro.Schema schema, String url, int identityMapCapacity)
ConfluentRegistryAvroDeserializationSchema
that produces GenericRecord
using provided reader schema and looks up writer schema in Confluent Schema Registry.schema
- schema of produced recordsurl
- url of schema registry to connectidentityMapCapacity
- maximum number of cached schema versions (default: 1000)GenericRecord
public static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T> forSpecific(Class<T> tClass, String url)
AvroDeserializationSchema
that produces classes that were generated from avro
schema and looks up writer schema in Confluent Schema Registry.tClass
- class of record to be producedurl
- url of schema registry to connectpublic static <T extends org.apache.avro.specific.SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T> forSpecific(Class<T> tClass, String url, int identityMapCapacity)
AvroDeserializationSchema
that produces classes that were generated from avro
schema and looks up writer schema in Confluent Schema Registry.tClass
- class of record to be producedurl
- url of schema registry to connectidentityMapCapacity
- maximum number of cached schema versions (default: 1000)Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.