seatunnel win idea 本地调试

调试FakeSource，LocalFile

# Set the basic configuration of the task to be performed
env {
  execution.parallelism = 1
  job.mode = "BATCH"
}

# Create a source to connect to Mongodb
source {
  # This is a example source plugin **only for test and demonstrate the feature source plugin**
  FakeSource {
    parallelism = 2
    result_table_name = "fake"
    row.num = 16
    schema = {
      fields {
        name = "string"
        age = "int"
      }
    }
  }
}

sink {

LocalFile {
    path = "/tmp/seatunnel/excel"
	file_format_type="excel"
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

调试前准备工作:

1.导入需要的connector
1

2.启动依赖Hadoop，设置Hadoop环境变量，记得安装Hadoop，放入winutils.exe
1

3.将配置文件放入到代码里面的resource目录下
4.运行类
org.apache.seatunnel.example.engine.SeaTunnelEngineExample
1
2
3