org.apache.flink.table.descriptors

Class SchemaValidator

java.lang.Object

org.apache.flink.table.descriptors.SchemaValidator

All Implemented Interfaces:

DescriptorValidator

Deprecated.

See Schema for details.

@PublicEvolving
 @Deprecated
public class SchemaValidator
extends Object
implements DescriptorValidator

Validator for Schema.

Constructor Summary

Constructors

Constructor and Description
SchemaValidator(boolean isStreamEnvironment, boolean supportsSourceTimestamps, boolean supportsSourceWatermarks) Deprecated.

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	deriveFieldMapping(DescriptorProperties properties, Optional<TypeInformation<?>> inputType) Deprecated. Finds a table source field mapping.
static Optional<String>	deriveProctimeAttribute(DescriptorProperties properties) Deprecated. Finds the proctime attribute if defined.
static List<RowtimeAttributeDescriptor>	deriveRowtimeAttributes(DescriptorProperties properties) Deprecated. Finds the rowtime attributes if defined.
static TableSchema	deriveTableSinkSchema(DescriptorProperties properties) Deprecated. This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).
void	validate(DescriptorProperties properties) Deprecated. 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

Constructor Detail

SchemaValidator

public SchemaValidator(boolean isStreamEnvironment,
                       boolean supportsSourceTimestamps,
                       boolean supportsSourceWatermarks)

Deprecated.

Method Detail

validate

public void validate(DescriptorProperties properties)

Deprecated.

Description copied from interface: DescriptorValidator

Performs basic validation such as completeness tests.

Specified by:

validate in interface DescriptorValidator

deriveProctimeAttribute

public static Optional<String> deriveProctimeAttribute(DescriptorProperties properties)

Deprecated.

Finds the proctime attribute if defined.

deriveRowtimeAttributes

public static List<RowtimeAttributeDescriptor> deriveRowtimeAttributes(DescriptorProperties properties)

Deprecated.

Finds the rowtime attributes if defined.

deriveTableSinkSchema

@Deprecated
public static TableSchema deriveTableSinkSchema(DescriptorProperties properties)

Deprecated. This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).

Derives the table schema for a table sink. A sink ignores a proctime attribute and needs to track the origin of a rowtime field.

deriveFieldMapping

public static Map<String,String> deriveFieldMapping(DescriptorProperties properties,
                                                    Optional<TypeInformation<?>> inputType)

Deprecated.

Finds a table source field mapping.

Parameters:

properties - The properties describing a schema.

inputType - The input type that a connector and/or format produces. This parameter can be used to resolve a rowtime field against an input field.