THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
As a result, #connect has been deprecated sind Flink 1.11. In this FLIP, we want to propose a new API to programmatically define sources and sinks on the Table API without having to switch to SQL DDL.
Public Interfaces
Interface | Change | Comment |
---|---|---|
TableEnvironment | ||
#connect | Remove | Deprecated since Flink 1.11 |
#createTable(path, TableDescriptor) | New | |
#createTemporaryTable(path, TableDescriptor) | New | |
#from(TableDescriptor) | New | |
Table | ||
#executeInsert(TableDescriptor) | New | |
Other | ||
ConnectTableDescriptor | Remove | |
BatchTableDescriptor | Remove | |
StreamTableDescriptor | Remove | |
ConnectorDescriptor | Remove | |
TableDescriptor | Refactor |
|
Rowtime | Remove |
TableEnvironment#createTable & TableEnvironment#createTemporaryTable
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
TableDescriptor { // Create a builder static TableDescriptorBuilder forConnector(String connector); @Nullable Schema getSchema(); Map<String, String> getOptions(); @Nullable String getComment(); List<String> getPartitionKeys(); @Nullable TableLikeDescriptor getLikeDescriptor(); } TableDescriptorBuilder<SELF> { SELF schema(Schema schema); SELF comment(String comment); SELF option<T>(ConfigOption<T> configOption, T value); SELF option(String key, String value); SELF format(String format); SELF format(ConfigOption<?> formatOption, String format); SELF format(FormatDescriptor formatDescriptor); SELF format(ConfigOption<?> formatOption, FormatDescriptor formatDescriptor); SELF partitionedBy(String... partitionKeys); SELF like(String tableName, LikeOption... likeOptions); TableDescriptor build(); } TableLikeDescriptor { String getTableName(); List<TableLikeOption> getLikeOptions(); } FormatDescriptor { static FormatDescriptorBuilder forFormat(String format); String getFormat(); Map<String, String> getOptions(); } FormatDescriptorBuilder<SELF> { SELF option<T>(ConfigOption<T> configOption, T value); SELF option(String key, String value); FormatDescriptor build(); } interface LikeOption { enum INCLUDING implements LikeOption { ALL, CONSTRAINTS, GENERATED, OPTIONS, PARTITIONS, WATERMARKS } enum EXCLUDING implements LikeOption { ALL, CONSTRAINTS, GENERATED, OPTIONS, PARTITIONS, WATERMARKS } enum OVERWRITING implements LikeOption { GENERATED, OPTIONS, WATERMARKS } } |
...