[
https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-25760:
--------------------------
Description:
Supports custom SQL syntax, similar to Spark Extensions Feature. Custom SQL
syntax can be implemented. example:
{code:java}
datax reader('数据类型名称') options(键值对参数)
[filter('filter action name') options(键值对参数)]*
writer('数据类型名称') options(键值对参数)
datax reader("jdbc") options(
username="dataworks",
password="dataworks2021",
type="mysql",
url="jdbc:mysql://10.5.20.20:3306",
databaseName='dataworks', tableName='dc_datax_datasource', column=["*"])
writer("hive") options(databaseName="bigdata",
tableName='hive_datax_datasource', writeMode='overwrite', column=["*"]); {code}
https://github.com/melin/datatunnel
was:Supports extended SQL syntax, similar to Spark Extensions Feature. Custom
SQL syntax can be implemented
> Support custom SQL syntax
> -------------------------
>
> Key: FLINK-25760
> URL: https://issues.apache.org/jira/browse/FLINK-25760
> Project: Flink
> Issue Type: Improvement
> Reporter: melin
> Priority: Major
>
> Supports custom SQL syntax, similar to Spark Extensions Feature. Custom SQL
> syntax can be implemented. example:
> {code:java}
> datax reader('数据类型名称') options(键值对参数)
> [filter('filter action name') options(键值对参数)]*
> writer('数据类型名称') options(键值对参数)
> datax reader("jdbc") options(
> username="dataworks",
> password="dataworks2021",
> type="mysql",
> url="jdbc:mysql://10.5.20.20:3306",
> databaseName='dataworks', tableName='dc_datax_datasource', column=["*"])
> writer("hive") options(databaseName="bigdata",
> tableName='hive_datax_datasource', writeMode='overwrite', column=["*"]);
> {code}
> https://github.com/melin/datatunnel
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
