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 |
SourceSinkTableEntry.validate(DescriptorProperties properties) |
protected void |
SourceTableEntry.validate(DescriptorProperties properties) |
protected void |
DeploymentEntry.validate(DescriptorProperties properties) |
protected void |
CatalogEntry.validate(DescriptorProperties properties) |
protected void |
ConfigurationEntry.validate(DescriptorProperties properties) |
protected void |
ModuleEntry.validate(DescriptorProperties properties) |
protected void |
ExecutionEntry.validate(DescriptorProperties properties) |
protected void |
ViewEntry.validate(DescriptorProperties properties) |
protected void |
TemporalTableEntry.validate(DescriptorProperties properties) |
protected void |
SinkTableEntry.validate(DescriptorProperties properties) |
protected void |
FunctionEntry.validate(DescriptorProperties properties) |
Constructor and Description |
---|
CatalogEntry(String name,
DescriptorProperties properties) |
ModuleEntry(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 |
ClassInstance.addPropertiesWithPrefix(String keyPrefix,
DescriptorProperties properties)
Internal method for properties conversion.
|
void |
LiteralValue.addPropertiesWithPrefix(String keyPrefix,
DescriptorProperties properties) |
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.
|
static boolean |
KafkaValidator.hasConciseKafkaProperties(DescriptorProperties descriptorProperties) |
void |
DescriptorProperties.putProperties(DescriptorProperties otherProperties)
Adds a set of descriptor properties.
|
void |
KafkaValidator.validate(DescriptorProperties properties) |
void |
JdbcValidator.validate(DescriptorProperties properties) |
void |
JdbcCatalogValidator.validate(DescriptorProperties properties) |
void |
CsvValidator.validate(DescriptorProperties properties) |
void |
AvroValidator.validate(DescriptorProperties properties) |
void |
AbstractHBaseValidator.validate(DescriptorProperties properties) |
void |
ElasticsearchValidator.validate(DescriptorProperties properties) |
void |
JsonValidator.validate(DescriptorProperties properties) |
void |
RowtimeValidator.validate(DescriptorProperties properties) |
void |
OldCsvValidator.validate(DescriptorProperties properties)
Deprecated.
|
void |
SchemaValidator.validate(DescriptorProperties properties) |
void |
GenericInMemoryCatalogValidator.validate(DescriptorProperties properties) |
void |
DescriptorValidator.validate(DescriptorProperties properties)
Performs basic validation such as completeness tests.
|
void |
FileSystemValidator.validate(DescriptorProperties properties) |
void |
CatalogDescriptorValidator.validate(DescriptorProperties properties) |
void |
PythonFunctionValidator.validate(DescriptorProperties properties) |
void |
FunctionDescriptorValidator.validate(DescriptorProperties properties) |
void |
ModuleDescriptorValidator.validate(DescriptorProperties properties) |
void |
ConnectorDescriptorValidator.validate(DescriptorProperties properties) |
void |
CoreModuleDescriptorValidator.validate(DescriptorProperties properties) |
void |
FormatDescriptorValidator.validate(DescriptorProperties properties) |
void |
StreamTableDescriptorValidator.validate(DescriptorProperties properties) |
void |
HierarchyDescriptorValidator.validate(DescriptorProperties properties) |
static List<ElasticsearchUpsertTableSinkBase.Host> |
ElasticsearchValidator.validateAndParseHostsString(DescriptorProperties descriptorProperties)
Parse Hosts String to list.
|
static Map<Integer,Long> |
KafkaValidator.validateAndParseSpecificOffsetsString(DescriptorProperties descriptorProperties)
Parse SpecificOffsets String to Map.
|
protected void |
LiteralValueValidator.validateWithPrefix(String keyPrefix,
DescriptorProperties properties) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
HiveModuleDescriptorValidator.validate(DescriptorProperties properties) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.