public class Avro
extends org.apache.flink.table.descriptors.FormatDescriptor
Constructor and Description |
---|
Avro()
Format descriptor for Apache Avro records.
|
Modifier and Type | Method and Description |
---|---|
void |
addFormatProperties(org.apache.flink.table.descriptors.DescriptorProperties properties)
Internal method for format properties conversion.
|
Avro |
avroSchema(String avroSchema)
Sets the Avro schema for specific or generic Avro records.
|
Avro |
recordClass(Class<? extends org.apache.avro.specific.SpecificRecord> recordClass)
Sets the class of the Avro specific record.
|
public Avro recordClass(Class<? extends org.apache.avro.specific.SpecificRecord> recordClass)
recordClass
- class of the Avro record.public Avro avroSchema(String avroSchema)
avroSchema
- Avro schema stringpublic void addFormatProperties(org.apache.flink.table.descriptors.DescriptorProperties properties)
addFormatProperties
in class org.apache.flink.table.descriptors.FormatDescriptor
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.