diqiu50 opened a new pull request, #12244: URL: https://github.com/apache/gravitino/pull/12244
### What changes were proposed in this pull request? Added an overridable `toGravitinoType(LogicalType)` hook in `BaseCatalog` (Flink connector), replacing the hardcoded static `TypeUtils.toGravitinoType` calls with calls to this instance method. ### Why are the changes needed? The Flink connector's type conversion (`TypeUtils.toGravitinoType`) had no per-catalog override point, unlike the Spark and Trino connectors, which already special-case certain JDBC catalogs for type-mapping quirks (e.g. `SparkTypeConverter`). This adds the same extension point to the Flink connector so catalog-specific subclasses can override type mapping where needed. ### Does this PR introduce any user-facing change? No public API change. `BaseCatalog` subclasses can now override `toGravitinoType` to customize column type mapping. ### How was this patch tested? Existing `TestBaseCatalog` suite updated to construct catalogs via the `TestableBaseCatalog` test helper instead of calling static methods, and passes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
