Package org.apache.flink.table.descriptors

Class SchemaValidator

java.lang.Object

org.apache.flink.table.descriptors.SchemaValidator

All Implemented Interfaces:

org.apache.flink.table.descriptors.DescriptorValidator

@PublicEvolving
@Deprecated
public class SchemaValidator
extends Object
implements org.apache.flink.table.descriptors.DescriptorValidator

Deprecated.

See Schema for details.

Validator for Schema.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	deriveFieldMapping(org.apache.flink.table.descriptors.DescriptorProperties properties, Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>> inputType)	Deprecated. Finds a table source field mapping.
static Optional<String>	deriveProctimeAttribute(org.apache.flink.table.descriptors.DescriptorProperties properties)	Deprecated. Finds the proctime attribute if defined.
static List<org.apache.flink.table.sources.RowtimeAttributeDescriptor>	deriveRowtimeAttributes(org.apache.flink.table.descriptors.DescriptorProperties properties)	Deprecated. Finds the rowtime attributes if defined.
static org.apache.flink.table.api.TableSchema	deriveTableSinkSchema(org.apache.flink.table.descriptors.DescriptorProperties properties)	Deprecated. This method combines two separate concepts of table schema and field mapping.
void	validate(org.apache.flink.table.descriptors.DescriptorProperties properties)	Deprecated.

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(org.apache.flink.table.descriptors.DescriptorProperties properties)

Deprecated.

Specified by:

validate in interface org.apache.flink.table.descriptors.DescriptorValidator

deriveProctimeAttribute

public static Optional<String> deriveProctimeAttribute(org.apache.flink.table.descriptors.DescriptorProperties properties)

Deprecated.

Finds the proctime attribute if defined.

deriveRowtimeAttributes

public static List<org.apache.flink.table.sources.RowtimeAttributeDescriptor> deriveRowtimeAttributes(org.apache.flink.table.descriptors.DescriptorProperties properties)

Deprecated.

Finds the rowtime attributes if defined.

deriveTableSinkSchema

@Deprecated
public static org.apache.flink.table.api.TableSchema deriveTableSinkSchema(org.apache.flink.table.descriptors.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(org.apache.flink.table.descriptors.DescriptorProperties properties,
                                                          Optional<org.apache.flink.api.common.typeinfo.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.