Package | Description |
---|---|
org.apache.flink.table.client.config | |
org.apache.flink.table.client.config.entries | |
org.apache.flink.table.descriptors |
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 |
TemporalTableEntry.validate(DescriptorProperties properties) |
protected void |
FunctionEntry.validate(DescriptorProperties properties) |
protected void |
SinkTableEntry.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 |
---|
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 |
DescriptorProperties.putProperties(DescriptorProperties otherProperties)
Adds a set of descriptor properties.
|
void |
CsvValidator.validate(DescriptorProperties properties) |
void |
AvroValidator.validate(DescriptorProperties properties) |
void |
ElasticsearchValidator.validate(DescriptorProperties properties) |
void |
JsonValidator.validate(DescriptorProperties properties) |
void |
KafkaValidator.validate(DescriptorProperties properties) |
void |
ConnectorDescriptorValidator.validate(DescriptorProperties properties) |
void |
FormatDescriptorValidator.validate(DescriptorProperties properties) |
void |
DescriptorValidator.validate(DescriptorProperties properties)
Performs basic validation such as completeness tests.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.