[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory
[
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)
[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory
[
https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12991:
---
Labels: pull-request-available (was: )
> 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
>Priority: Major
> Labels: pull-request-available
>
> 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
(v7.6.3#76005)
[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory
[
https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-12991:
Description:
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.
was:
The following method is added in catalog.py in FLINK-11480:
{code:java}
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.
> 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
>Priority: Major
>
> 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
(v7.6.3#76005)
[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory
[
https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-12991:
Description:
The following method is added in catalog.py in FLINK-11480:
{code:java}
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.
was:
The following method is added in catalog.py in FLINK-11480:
{code:java}
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 it 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 will be used by users directly, we need to provide a Python
TableFactory wrapper and makes sure the 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.
> 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
>Priority: Major
>
> The following method is added in catalog.py in FLINK-11480:
> {code:java}
> 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
(v7.6.3#76005)
