-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Closed
Labels
area/spark-connectorIssues or PRs related to Spark connectorIssues or PRs related to Spark connectorkind/featureCategorizes issue or PR as related to a new feature.Categorizes issue or PR as related to a new feature.
Description
Refer to Spark Doris Connector test method Flink Connector
- Support reading doris data through Flink to construct DataStream
- 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'
);
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
area/spark-connectorIssues or PRs related to Spark connectorIssues or PRs related to Spark connectorkind/featureCategorizes issue or PR as related to a new feature.Categorizes issue or PR as related to a new feature.