Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
ConnectTableDescriptor |
TableEnvironment.connect(ConnectorDescriptor connectorDescriptor)
Deprecated.
The SQL
CREATE TABLE DDL is richer than this part of the API. This method
might be refactored in the next versions. Please use executeSql(ddl) to register a table instead. |
Modifier and Type | Method and Description |
---|---|
ConnectTableDescriptor |
TableEnvironmentImpl.connect(ConnectorDescriptor connectorDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
BatchTableDescriptor
Describes a table connected from a batch environment.
|
class |
StreamTableDescriptor
Describes a table connected from a streaming environment.
|
Modifier and Type | Method and Description |
---|---|
ConnectTableDescriptor |
ConnectTableDescriptor.withPartitionKeys(List<String> partitionKeys)
Specifies the partition keys of this table.
|
ConnectTableDescriptor |
ConnectTableDescriptor.withSchema(Schema schema)
Specifies the resulting table schema.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.