org.apache.flink.table.descriptors

类 SchemaValidator

java.lang.Object

org.apache.flink.table.descriptors.SchemaValidator

所有已实现的接口:

org.apache.flink.table.descriptors.DescriptorValidator

已过时。

See Schema for details.

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

Validator for Schema.

构造器概要

构造器

构造器和说明
SchemaValidator(boolean isStreamEnvironment, boolean supportsSourceTimestamps, boolean supportsSourceWatermarks) 已过时。

方法概要

限定符和类型	方法和说明
static Map<String,String>	deriveFieldMapping(org.apache.flink.table.descriptors.DescriptorProperties properties, Optional<org.apache.flink.api.common.typeinfo.TypeInformation<?>> inputType) 已过时。 Finds a table source field mapping.
static Optional<String>	deriveProctimeAttribute(org.apache.flink.table.descriptors.DescriptorProperties properties) 已过时。 Finds the proctime attribute if defined.
static List<org.apache.flink.table.sources.RowtimeAttributeDescriptor>	deriveRowtimeAttributes(org.apache.flink.table.descriptors.DescriptorProperties properties) 已过时。 Finds the rowtime attributes if defined.
static org.apache.flink.table.api.TableSchema	deriveTableSinkSchema(org.apache.flink.table.descriptors.DescriptorProperties properties) 已过时。 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).
static List<String>	getSchemaDerivationKeys() 已过时。 Returns keys for a TableFormatFactory.supportedProperties() method that are accepted for schema derivation using deriveFormatFields(DescriptorProperties).
void	validate(org.apache.flink.table.descriptors.DescriptorProperties properties) 已过时。

从类继承的方法 java.lang.Object

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

构造器详细资料

SchemaValidator

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

已过时。

方法详细资料

validate

public void validate(org.apache.flink.table.descriptors.DescriptorProperties properties)

已过时。

指定者:

validate 在接口中 org.apache.flink.table.descriptors.DescriptorValidator

getSchemaDerivationKeys

public static List<String> getSchemaDerivationKeys()

已过时。

Returns keys for a TableFormatFactory.supportedProperties() method that are accepted for schema derivation using deriveFormatFields(DescriptorProperties).

deriveProctimeAttribute

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

已过时。

Finds the proctime attribute if defined.

deriveRowtimeAttributes

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

已过时。

Finds the rowtime attributes if defined.

deriveTableSinkSchema

@Deprecated
public static org.apache.flink.table.api.TableSchema deriveTableSinkSchema(org.apache.flink.table.descriptors.DescriptorProperties properties)

已过时。 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)

已过时。

Finds a table source field mapping.

参数:

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.