This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from de44e09 [FLINK-14943][Connector/Kafka] Expose callback and related
fields to subclasses for override
add 773b680 [FLINK-14978][table-api] Introduce constraint class hierarchy
required for primary keys
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/table/api/TableSchema.java | 121 +++++++++++++++++--
.../constraints/AbstractConstraint.java} | 40 +++---
.../flink/table/api/constraints/Constraint.java | 66 ++++++++++
.../table/api/constraints/UniqueConstraint.java | 113 +++++++++++++++++
.../apache/flink/table/api/TableSchemaTest.java | 134 +++++++++++++++++++++
.../api/constraints/UniqueConstraintTest.java | 32 +++--
6 files changed, 467 insertions(+), 39 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{types/inference/strategies/ExplicitTypeStrategy.java
=> api/constraints/AbstractConstraint.java} (59%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/Constraint.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java
copy
flink-core/src/test/java/org/apache/flink/util/JavaGcCleanerWrapperTest.java =>
flink-table/flink-table-common/src/test/java/org/apache/flink/table/api/constraints/UniqueConstraintTest.java
(55%)
