T
- type of record it producespublic class ConfluentRegistryAvroDeserializationSchema<T> extends RegistryAvroDeserializationSchema<T>
SchemaCoder
that
uses Confluent Schema Registry.DeserializationSchema.InitializationContext
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
deserialize, open
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–2021 The Apache Software Foundation. All rights reserved.