hf200012 opened a new issue #5371:
URL: https://github.com/apache/incubator-doris/issues/5371
Refer to Spark Doris Connector test method Flink Connector
1. Support reading doris data through Flink to construct DataStream
2. Support to create Flink table mapping doris table through Flink SQL to
read doris data, example:
CREATE TABLE myUserTable (
user_id STRING,
user_name STRING
uv BIGINT,
pv BIGINT,
PRIMARY KEY (user_id) NOT ENFORCED
) WITH (
'connector' ='doris',
'fe.host' ='ip:port',
'username' ='users',
'password' ='password',
'tableName' ='table1'
);
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
