| Package | Description |
|---|---|
| org.apache.flink.formats.avro |
| Modifier and Type | Class and Description |
|---|---|
class |
RegistryAvroSerializationSchema<T>
Serialization schema that serializes to Avro format.
|
| Modifier and Type | Method and Description |
|---|---|
static AvroSerializationSchema<org.apache.avro.generic.GenericRecord> |
AvroSerializationSchema.forGeneric(org.apache.avro.Schema schema)
Creates
AvroSerializationSchema that serializes GenericRecord using provided
schema. |
static AvroSerializationSchema<org.apache.avro.generic.GenericRecord> |
AvroSerializationSchema.forGeneric(org.apache.avro.Schema schema,
AvroFormatOptions.AvroEncoding encoding)
Creates
AvroSerializationSchema that serializes GenericRecord using provided
schema. |
static <T extends org.apache.avro.specific.SpecificRecord> |
AvroSerializationSchema.forSpecific(Class<T> tClass)
Creates
AvroSerializationSchema that serializes SpecificRecord using provided
schema. |
static <T extends org.apache.avro.specific.SpecificRecord> |
AvroSerializationSchema.forSpecific(Class<T> tClass,
AvroFormatOptions.AvroEncoding encoding)
Creates
AvroSerializationSchema that serializes SpecificRecord using provided
schema. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.