[
https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-12991:
----------------------------
Fix Version/s: 1.9.0
> Correct the implementation of Catalog.get_table_factory
> -------------------------------------------------------
>
> Key: FLINK-12991
> URL: https://issues.apache.org/jira/browse/FLINK-12991
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Reporter: Dian Fu
> Assignee: Dian Fu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.9.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> The following method is added in catalog.py in FLINK-11480:
> {code}
> def get_table_factory(self):
> """
> Get an optional TableFactory instance that's responsible for generating
> source/sink for tables stored in this catalog.
>
> :return: An optional TableFactory instance.
> """
> return self._j_catalog.getTableFactory()
> {code}
> There is some problem with the implementation as it returns a Java
> TableFactory and this is not friendly for Python users. We should correct the
> implementation.
> Before doing that, we need to make sure the following thing:
> Is this method designed to be used by users or will only be used internally?
> I take a quick look at the code and it seems to me that this method will only
> be used internally. Maybe [~xuefuz] and [~phoenixjiangnan] can provide more
> information about this.
> If this method is designed to be used by users directly, we need to provide a
> Python TableFactory wrapper and makes sure this method is usable for Python
> users. If this method is designed to be only used internally, then we need to
> remove it from the Python catalog. For the API completeness test, we can add
> this method to *excluded_methods* of *CatalogAPICompletenessTests* to make
> the tests passed.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
