Modifier and Type | Method and Description |
---|---|
void |
HiveCatalogValidator.validate(DescriptorProperties properties) |
Modifier and Type | Method and Description |
---|---|
static DescriptorProperties |
ConfigUtil.normalizeYaml(Map<String,Object> yamlMap)
Normalizes key-value properties from Yaml in the normalized format of the Table API.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DeploymentEntry.validate(DescriptorProperties properties) |
protected void |
CatalogEntry.validate(DescriptorProperties properties) |
protected void |
TemporalTableEntry.validate(DescriptorProperties properties) |
protected void |
FunctionEntry.validate(DescriptorProperties properties) |
protected void |
SinkTableEntry.validate(DescriptorProperties properties) |
protected void |
ConfigurationEntry.validate(DescriptorProperties properties) |
protected void |
ViewEntry.validate(DescriptorProperties properties) |
protected void |
ExecutionEntry.validate(DescriptorProperties properties) |
protected void |
SourceTableEntry.validate(DescriptorProperties properties) |
protected void |
SourceSinkTableEntry.validate(DescriptorProperties properties) |
Constructor and Description |
---|
CatalogEntry(String name,
DescriptorProperties properties) |
TableEntry(String name,
DescriptorProperties properties) |
Modifier and Type | Method and Description |
---|---|
DescriptorProperties |
DescriptorProperties.withoutKeys(List<String> keys)
Returns a new properties instance with the given keys removed.
|
Modifier and Type | Method and Description |
---|---|
void |
LiteralValue.addPropertiesWithPrefix(String keyPrefix,
DescriptorProperties properties) |
void |
ClassInstance.addPropertiesWithPrefix(String keyPrefix,
DescriptorProperties properties)
Internal method for properties conversion.
|
abstract void |
HierarchyDescriptor.addPropertiesWithPrefix(String keyPrefix,
DescriptorProperties properties)
Internal method for properties conversion.
|
static Map<String,String> |
SchemaValidator.deriveFieldMapping(DescriptorProperties properties,
Optional<TypeInformation<?>> inputType)
Finds a table source field mapping.
|
static Optional<String> |
SchemaValidator.deriveProctimeAttribute(DescriptorProperties properties)
Finds the proctime attribute if defined.
|
static List<RowtimeAttributeDescriptor> |
SchemaValidator.deriveRowtimeAttributes(DescriptorProperties properties)
Finds the rowtime attributes if defined.
|
static TableSchema |
SchemaValidator.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).
|
static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> |
RowtimeValidator.getRowtimeComponents(DescriptorProperties properties,
String prefix) |
static Object |
LiteralValueValidator.getValue(String keyPrefix,
DescriptorProperties properties)
Gets the value according to the type and value strings.
|
void |
DescriptorProperties.putProperties(DescriptorProperties otherProperties)
Adds a set of descriptor properties.
|
static Map<String,ColumnStats> |
StatisticsValidator.readColumnStats(DescriptorProperties properties,
String key) |
void |
AvroValidator.validate(DescriptorProperties properties) |
void |
CsvValidator.validate(DescriptorProperties properties) |
void |
ElasticsearchValidator.validate(DescriptorProperties properties) |
void |
JsonValidator.validate(DescriptorProperties properties) |
void |
KafkaValidator.validate(DescriptorProperties properties) |
void |
HBaseValidator.validate(DescriptorProperties properties) |
void |
JDBCValidator.validate(DescriptorProperties properties) |
void |
OldCsvValidator.validate(DescriptorProperties properties)
Deprecated.
|
void |
RowtimeValidator.validate(DescriptorProperties properties) |
void |
SchemaValidator.validate(DescriptorProperties properties) |
void |
GenericInMemoryCatalogValidator.validate(DescriptorProperties properties) |
void |
ConnectorDescriptorValidator.validate(DescriptorProperties properties) |
void |
FormatDescriptorValidator.validate(DescriptorProperties properties) |
void |
FileSystemValidator.validate(DescriptorProperties properties) |
void |
ExternalCatalogDescriptorValidator.validate(DescriptorProperties properties)
Deprecated.
|
void |
StatisticsValidator.validate(DescriptorProperties properties) |
void |
StreamTableDescriptorValidator.validate(DescriptorProperties properties) |
void |
HierarchyDescriptorValidator.validate(DescriptorProperties properties) |
void |
CatalogDescriptorValidator.validate(DescriptorProperties properties) |
void |
DescriptorValidator.validate(DescriptorProperties properties)
Performs basic validation such as completeness tests.
|
void |
MetadataValidator.validate(DescriptorProperties properties) |
void |
FunctionDescriptorValidator.validate(DescriptorProperties properties) |
static void |
StatisticsValidator.validateColumnStats(DescriptorProperties properties,
String key) |
protected void |
ClassInstanceValidator.validateWithPrefix(String keyPrefix,
DescriptorProperties properties) |
protected abstract void |
HierarchyDescriptorValidator.validateWithPrefix(String keyPrefix,
DescriptorProperties properties)
Performs validation with a prefix for the keys.
|
protected void |
LiteralValueValidator.validateWithPrefix(String keyPrefix,
DescriptorProperties properties) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.