1{
2  "_db_jobMeta": {
3    "name": "oracle_orders_to_iceberg_batch",
4    "description": "Oracle ORDERS 表离线同步到 Iceberg",
5    "parentFolderId": "project_91cc_799bd26eee94",
6    "type": "batch",
7    "mode": "script"
8  },
9  "env": {
10    "job.mode": "BATCH",
11    "parallelism": 1,
12    "checkpoint.interval": 30000
13  },
14  "source": [
15    {
16      "plugin_name": "Jdbc",
17      "_db_pluginId": "Jdbc-Oracle",
18      "plugin_output": "source_table",
19      "_db_connectionId": "oracle-conn-001",
20      "_db_sourceDatabase": "ORCL",
21      "_db_sourceTable": "ORDERS",
22      "_db_where": "UPDATED_AT >= ${logicTime(yyyy-MM-dd HH:mm:ss,-1d)}",
23      "partition_column": "ID",
24      "_db_sourceChange": {
25        "onDeleteColumn": "SKIP",
26        "onAddColumn": "SKIP",
27        "onDeleteSource": "PAUSE"
28      }
29    }
30  ],
31  "sink": [
32    {
33      "plugin_name": "Iceberg",
34      "_db_pluginId": "Iceberg-batch",
35      "plugin_input": "source_table",
36      "_db_sinkPath": "lake.default",
37      "_db_catalog": "lake",
38      "_db_schema": "default",
39      "iceberg.table.upsert-mode-enabled": false,
40      "data_save_mode": "APPEND_DATA",
41      "_db_isAutoCreated": true,
42      "_db_sinkTableType": "MANAGED",
43      "_db_sinkNameRule": "SAME",
44      "_db_comment": "订单表"
45    }
46  ]
47}

1{
2  "_db_jobMeta": {
3    "name": "oracle_orders_to_iceberg_streaming",
4    "description": "Oracle ORDERS 表 CDC 同步到 Iceberg",
5    "parentFolderId": "folder_af42_bccdb16a1d00",
6    "type": "streaming",
7    "mode": "script",
8    "syncMode": "INCREMENT"
9  },
10  "env": {
11    "job.mode": "STREAMING",
12    "parallelism": 1,
13    "_db_enableCheckpoint": false
14  },
15  "source": [
16    {
17      "plugin_name": "Oracle-CDC",
18      "_db_pluginId": "Oracle-CDC",
19      "plugin_output": "source_table",
20      "_db_connectionId": "oracle-cdc-conn-001",
21      "_db_sourceDatabase": "ORCL",
22      "_db_syncMode": "INCREMENT",
23      "_db_incrementPosition": {
24        "type": "CURRENT_TIME",
25        "position": ""
26      }
27    }
28  ],
29  "sink": [
30    {
31      "plugin_name": "Iceberg",
32      "_db_pluginId": "Iceberg-streaming",
33      "plugin_input": "source_table",
34      "_db_sinkPath": "lake.default",
35      "_db_catalog": "lake",
36      "_db_schema": "default",
37      "_db_sinkTableType": "MANAGED"
38    }
39  ],
40  "_db_tableConfigs": [
41    {
42      "tableIdentity": {
43        "sourceTable": "ORDERS",
44        "sinkTable": "ods_orders"
45      },
46      "source": {
47        "_db_sourceChange": {
48          "onDeleteColumn": "SKIP",
49          "onAddColumn": "SKIP",
50          "onDeleteSource": "PAUSE",
51          "onRenameColumn": "SKIP",
52          "onTruncateTable": "SKIP",
53          "onRenameTable": "SKIP",
54          "onChangeColumn": "SKIP",
55          "onChangeTableComment": "SKIP",
56          "onChangeColumnComment": "SKIP"
57        }
58      },
59      "sink": {
60        "_db_isAutoCreated": true,
61        "_db_sinkNameRule": "SAME",
62        "_db_dmlConfig": {
63          "insert": "INSERT",
64          "update": "UPDATE",
65          "delete": "DELETE",
66          "logicalDeleteTag": ""
67        }
68      }
69    }
70  ]
71}