Bulk Operation

FLINK-16987 Metadata keys should not conflict with physical columns

FLINK-16987 DynamicTableFactory.Context.getCatalogTable().getPartitionKeys() should return indexes

FLINK-16987 Add producedDataType to SupportsProjectionPushDown.applyProjection

FLINK-16987 Push down partitions before filters

FLINK-16987 Non-equality predicates on partition columns lead to incorrect plans

FLINK-16987 Validate partition columns for ResolvedCatalogTable

FLINK-16987 Clarify semantics of filter, projection, partition, and metadata pushdown

FLINK-16987 Consider ConfigOption fallback keys in FactoryUtil

FLINK-16987 Allow prefix syntax for ConfigOption.mapType

FLINK-16987 Add a SupportsSourceWatermark ability interface

FLINK-16987 predicates can not be pushed into TableScan when there is a WatermarkAssigner between Filter and Scan

FLINK-16987 Remove deprecated CatalogTable.getProperties

FLINK-16987 Support Watermark push down for kafka connector

FLINK-16987 Supports nested projection pushdown for filesystem connector of columnar format

FLINK-16987 Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

FLINK-16987 Support the filter push down for the Jdbc connector

FLINK-16987 Support the limit push down for the Jdbc connector

FLINK-16987 Support the nested projection push down for the hbase connector

FLINK-16987 Support the limit push down for the hbase connector

FLINK-16987 Support nested push down for SupportsProjectionPushDown interface in planner

FLINK-16987 Deprecate old source and sink interfaces

FLINK-16987 Support watermark push down with WatermarkStrategy

FLINK-16987 Support the SupportsFilterPushDown interface for LookupTableSource

FLINK-16987 Support the SupportsProjectionPushDown interface for LookupTableSource

FLINK-16987 Use new data structure converters when legacy types are not present

FLINK-16987 Support to bridge Transformation (DataStream) with FLIP-95 interface?

FLINK-16987 Support to integrate FLIP-27 source interface with Table API

FLINK-16987 Add a table source example

FLINK-16987 Update the Row.toString method

FLINK-16987 Add documentation for how to develop a new table source/sink

FLINK-16987 Improve interface of ScanFormatFactory and SinkFormatFactory

FLINK-16987 Remove deprecated RowData.get and similar methods

FLINK-16987 Add createTypeInformation to DynamicTableSink#Context

FLINK-16987 Fix shortcomings in new data structures

FLINK-16987 Improve new connector options exception in old planner

FLINK-16987 SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter

FLINK-16987 Support SupportsPartitioning in planner

FLINK-16987 Support SupportsOverwrite in planner

FLINK-16987 Support SupportsProjectionPushDown in planner

FLINK-16987 Support SupportsPartitionPushDown in planner

FLINK-16987 Support SupportsLimitPushDown in planner

FLINK-16987 Support SupportsFilterPushDown in planner

FLINK-16987 Refactor BaseRow to use RowKind instead of byte header

FLINK-16987 Type information in sources should cover all data structures

FLINK-16987 Data structure should cover all conversions declared in logical types

FLINK-16987 Add a changeflag to Row type

FLINK-16987 Add new factory interfaces and utilities

FLINK-16987 Refactor planner and connectors to use new data structures

FLINK-16987 Add new data structure interfaces in table-common

FLINK-16987 Support SupportsWatermarkPushDown in planner

FLINK-16987 Support SupportsComputedColumnPushDown in planner

FLINK-16987 Add ability interfaces for table source/sink

FLINK-16987 Support DynamicTableSink in planner

FLINK-16987 Support LookupTableSource in planner

FLINK-16987 Support ScanTableSource in planner

FLINK-16987 Add core table source/sink interfaces

FLINK-16987 Refactor retraction rules to support inferring ChangelogMode