Seatunnel

The newest Apache SeaTunnel (waterdop) has supported Doris connector, seatunnel can load data by Spark engine or Flink engine.

In fact,seatunnel load data by stream load function.Everyone is welcome to use

Install Seatunnel

Seatunnel install

Spark Sink Doris

Options

fenodes [string]

Doris FE address:8030

database [string]

Doris target database name

table [string]

Doris target table name

user [string]

Doris user name

password [string]

Doris user’s password

batch_size [string]

Doris number of submissions per batch

doris. [string] Doris stream_load properties,you can use ‘doris.’ prefix + stream_load properties

More Doris stream_load Configurations

Examples

Hive to Doris

Config properties

1. env{
2. spark.app.name = "hive2doris-template"
3. }

5. spark {
6. spark.sql.catalogImplementation = "hive"
7. }

9. source {
10. hive {
11. preSql = "select * from tmp.test"
12. result_table_name = "test"
13. }
14. }

16. transform {
17. }

20. sink {

22. Console {

24. }

26. Doris {
27. fenodes="xxxx:8030"
28. database="gl_mint_dim"
29. table="dim_date"
30. user="root"
31. password="root"
32. batch_size=1000
33. doris.column_separator="\t"
34. doris.columns="date_key,date_value,day_in_year,day_in_month"
35. }
36. }

Start command

1. sh bin/start-waterdrop-spark.sh --master local[4] --deploy-mode client --config ./config/spark.conf