org.apache.flink.table.descriptors

Class AvroValidator

java.lang.Object

org.apache.flink.table.descriptors.FormatDescriptorValidator

org.apache.flink.table.descriptors.AvroValidator

All Implemented Interfaces:

DescriptorValidator

@Internal
public class AvroValidator
extends FormatDescriptorValidator

Validator for Avro.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FORMAT_AVRO_SCHEMA
static String	FORMAT_RECORD_CLASS
static String	FORMAT_TYPE_VALUE

Fields inherited from class org.apache.flink.table.descriptors.FormatDescriptorValidator

FORMAT, FORMAT_DERIVE_SCHEMA, FORMAT_PROPERTY_VERSION, FORMAT_TYPE, FORMAT_VERSION

Constructor Summary

Constructors

Constructor and Description
AvroValidator()

Method Summary

Modifier and Type	Method and Description
void	validate(DescriptorProperties properties) Performs basic validation such as completeness tests.

Methods inherited from class java.lang.Object

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

Field Detail

FORMAT_TYPE_VALUE

public static final String FORMAT_TYPE_VALUE

See Also:

Constant Field Values

FORMAT_RECORD_CLASS

public static final String FORMAT_RECORD_CLASS

See Also:

Constant Field Values

FORMAT_AVRO_SCHEMA

public static final String FORMAT_AVRO_SCHEMA

See Also:

Constant Field Values

Constructor Detail

AvroValidator

public AvroValidator()

Method Detail

validate

public void validate(DescriptorProperties properties)

Description copied from interface: DescriptorValidator

Performs basic validation such as completeness tests.

Specified by:

validate in interface DescriptorValidator

Overrides:

validate in class FormatDescriptorValidator