org.apache.flink.table.descriptors

Class Avro

java.lang.Object

org.apache.flink.table.descriptors.DescriptorBase

org.apache.flink.table.descriptors.FormatDescriptor

org.apache.flink.table.descriptors.Avro

All Implemented Interfaces:

org.apache.flink.table.descriptors.Descriptor

public class Avro
extends org.apache.flink.table.descriptors.FormatDescriptor

Format descriptor for Apache Avro records.

Constructor Summary

Constructors

Constructor and Description
Avro() Format descriptor for Apache Avro records.

Method Summary

Modifier and Type	Method and Description
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.
protected Map<String,String>	toFormatProperties()

Methods inherited from class org.apache.flink.table.descriptors.FormatDescriptor

toProperties

Methods inherited from class org.apache.flink.table.descriptors.DescriptorBase

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Avro

public Avro()

Format descriptor for Apache Avro records.

Method Detail

recordClass

public Avro recordClass(Class<? extends org.apache.avro.specific.SpecificRecord> recordClass)

Sets the class of the Avro specific record.

Parameters:

recordClass - class of the Avro record.

avroSchema

public Avro avroSchema(String avroSchema)

Sets the Avro schema for specific or generic Avro records.

Parameters:

avroSchema - Avro schema string

toFormatProperties

protected Map<String,String> toFormatProperties()

Specified by:

toFormatProperties in class org.apache.flink.table.descriptors.FormatDescriptor