You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jark Wu (Jira)" <ji...@apache.org> on 2020/05/10 03:12:00 UTC

[jira] [Assigned] (FLINK-17029) Introduce a new JDBC connector with new property keys

     [ https://issues.apache.org/jira/browse/FLINK-17029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu reassigned FLINK-17029:
-------------------------------

    Assignee: Leonard Xu

> Introduce a new JDBC connector with new property keys
> -----------------------------------------------------
>
>                 Key: FLINK-17029
>                 URL: https://issues.apache.org/jira/browse/FLINK-17029
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / JDBC, Table SQL / Ecosystem
>            Reporter: Jark Wu
>            Assignee: Leonard Xu
>            Priority: Major
>
> This new JDBC connector should use new interfaces proposed by FLIP-95, e.g. DynamicTableSource, DynamicTableSink, and Factory.
> The new proposed keys :
> ||Old key||New key||
> |connector.type|connector|
> |connector.url|url|
> |connector.table|table-name|
> |connector.driver|driver|
> |connector.username|username|
> |connector.password|password|
> |connector.read.partition.column|scan.partition.column|
> |connector.read.partition.num|scan.partition.num|
> |connector.read.partition.lower-bound|scan.partition.lower-bound|
> |connector.read.partition.upper-bound|scan.partition.upper-bound|
> |connector.read.fetch-size|scan.fetch-size|
> |connector.lookup.cache.max-rows|lookup.cache.max-rows|
> |connector.lookup.cache.ttl|lookup.cache.ttl|
> |connector.lookup.max-retries|lookup.max-retries|
> |connector.write.flush.max-rows|sink.buffer-flush.max-rows|
> |connector.write.flush.interval|sink.buffer-flush.interval|
> |connector.write.max-retries|sink.max-retries|
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)