Add source path in partial data synchronization (#785)

leto-b · web-flow · commit df076bf0c1ef · 2025-12-04T17:14:52.000+08:00
* fix iotdb enterprise edition to timechodb

* add source path in partial data synchronization

* remove other changes

* add scope param in table model
diff --git a/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md b/src/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
@@ -284,6 +284,7 @@ WITH SOURCE (
   'source' = 'iotdb-source',
   'mode.streaming' = 'true'  -- Extraction mode for newly inserted data (after the pipe is created): 
                              -- Whether to extract data in streaming mode (if set to false, batch mode is used).
+  'database-name'='testdb.*', -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The event time at which data synchronization starts (inclusive).
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The event time at which data synchronization ends (inclusive).
 ) 
diff --git a/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md b/src/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
@@ -294,6 +294,7 @@ WITH SOURCE (
   'source' = 'iotdb-source',
   'mode.streaming' = 'true'  -- Extraction mode for newly inserted data (after the pipe is created): 
                              -- Whether to extract data in streaming mode (if set to false, batch mode is used).
+  'database-name'='testdb.*', -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The event time at which data synchronization starts (inclusive).
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The event time at which data synchronization ends (inclusive).
 ) 
diff --git a/src/UserGuide/Master/Tree/User-Manual/Data-Sync_apache.md b/src/UserGuide/Master/Tree/User-Manual/Data-Sync_apache.md
@@ -289,6 +289,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/Master/Tree/User-Manual/Data-Sync_timecho.md b/src/UserGuide/Master/Tree/User-Manual/Data-Sync_timecho.md
@@ -297,6 +297,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/V1.3.x/User-Manual/Data-Sync_apache.md b/src/UserGuide/V1.3.x/User-Manual/Data-Sync_apache.md
@@ -289,6 +289,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/V1.3.x/User-Manual/Data-Sync_timecho.md b/src/UserGuide/V1.3.x/User-Manual/Data-Sync_timecho.md
@@ -297,6 +297,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/dev-1.3/User-Manual/Data-Sync_apache.md b/src/UserGuide/dev-1.3/User-Manual/Data-Sync_apache.md
@@ -289,6 +289,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/dev-1.3/User-Manual/Data-Sync_timecho.md b/src/UserGuide/dev-1.3/User-Manual/Data-Sync_timecho.md
@@ -297,6 +297,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md b/src/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
@@ -284,6 +284,7 @@ WITH SOURCE (
   'source' = 'iotdb-source',
   'mode.streaming' = 'true'  -- Extraction mode for newly inserted data (after the pipe is created): 
                              -- Whether to extract data in streaming mode (if set to false, batch mode is used).
+  'database-name'='testdb.*', -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The event time at which data synchronization starts (inclusive).
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The event time at which data synchronization ends (inclusive).
 ) 
diff --git a/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md b/src/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
@@ -294,6 +294,7 @@ WITH SOURCE (
   'source' = 'iotdb-source',
   'mode.streaming' = 'true'  -- Extraction mode for newly inserted data (after the pipe is created): 
                              -- Whether to extract data in streaming mode (if set to false, batch mode is used).
+  'database-name'='testdb.*', -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The event time at which data synchronization starts (inclusive).
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The event time at which data synchronization ends (inclusive).
 ) 
diff --git a/src/UserGuide/latest/User-Manual/Data-Sync_apache.md b/src/UserGuide/latest/User-Manual/Data-Sync_apache.md
@@ -289,6 +289,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/UserGuide/latest/User-Manual/Data-Sync_timecho.md b/src/UserGuide/latest/User-Manual/Data-Sync_timecho.md
@@ -297,6 +297,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)
+  'path' = 'root.vehicle.**',  -- Scope of Data Synchronization
   'start-time' = '2023.08.23T08:00:00+00:00',  -- The start event time for synchronizing all data, including start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- The end event time for synchronizing all data, including end-time
 ) 
diff --git a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_apache.md
@@ -277,6 +277,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'mode.streaming' = 'true'  -- 新插入数据（pipe创建后）的抽取模式：是否按流式抽取（false 时为批式）
+  'database-name'='testdb.*', -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/Master/Table/User-Manual/Data-Sync_timecho.md
@@ -291,6 +291,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'mode.streaming' = 'true'  -- 新插入数据（pipe创建后）的抽取模式：是否按流式抽取（false 时为批式）
+  'database-name'='testdb.*', -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/Master/Tree/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/Master/Tree/User-Manual/Data-Sync_apache.md
@@ -290,6 +290,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/Master/Tree/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/Master/Tree/User-Manual/Data-Sync_timecho.md
@@ -298,6 +298,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/V1.3.x/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/V1.3.x/User-Manual/Data-Sync_apache.md
@@ -290,6 +290,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/V1.3.x/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/V1.3.x/User-Manual/Data-Sync_timecho.md
@@ -298,6 +298,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/dev-1.3/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/dev-1.3/User-Manual/Data-Sync_apache.md
@@ -289,7 +289,8 @@ with sink (
 create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
-  'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'realtime.mode' = 'stream',  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/dev-1.3/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/dev-1.3/User-Manual/Data-Sync_timecho.md
@@ -298,6 +298,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_apache.md
@@ -277,6 +277,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'mode.streaming' = 'true'  -- 新插入数据（pipe创建后）的抽取模式：是否按流式抽取（false 时为批式）
+  'database-name'='testdb.*', -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/latest-Table/User-Manual/Data-Sync_timecho.md
@@ -291,6 +291,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'mode.streaming' = 'true'  -- 新插入数据（pipe创建后）的抽取模式：是否按流式抽取（false 时为批式）
+  'database-name'='testdb.*', -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/latest/User-Manual/Data-Sync_apache.md b/src/zh/UserGuide/latest/User-Manual/Data-Sync_apache.md
@@ -290,6 +290,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 
diff --git a/src/zh/UserGuide/latest/User-Manual/Data-Sync_timecho.md b/src/zh/UserGuide/latest/User-Manual/Data-Sync_timecho.md
@@ -298,6 +298,7 @@ create pipe A2B
 WITH SOURCE (
   'source'= 'iotdb-source',
   'realtime.mode' = 'stream'  -- 新插入数据（pipe创建后）的抽取模式
+  'path' = 'root.vehicle.**',  -- 同步数据的范围
   'start-time' = '2023.08.23T08:00:00+00:00',  -- 同步所有数据的开始 event time，包含 start-time
   'end-time' = '2023.10.23T08:00:00+00:00'  -- 同步所有数据的结束 event time，包含 end-time
 ) 

Original file line number	Diff line number	Diff line change
`@@ -284,6 +284,7 @@ WITH SOURCE (`
`284`	`284`	`'source' = 'iotdb-source',`
`285`	`285`	`'mode.streaming' = 'true' -- Extraction mode for newly inserted data (after the pipe is created):`
`286`	`286`	`-- Whether to extract data in streaming mode (if set to false, batch mode is used).`
	`287`	`+ 'database-name'='testdb.*', -- Scope of Data Synchronization`
`287`	`288`	`'start-time' = '2023.08.23T08:00:00+00:00', -- The event time at which data synchronization starts (inclusive).`
`288`	`289`	`'end-time' = '2023.10.23T08:00:00+00:00' -- The event time at which data synchronization ends (inclusive).`
`289`	`290`	`)`
Original file line number	Diff line number	Diff line change
`@@ -294,6 +294,7 @@ WITH SOURCE (`
`294`	`294`	`'source' = 'iotdb-source',`
`295`	`295`	`'mode.streaming' = 'true' -- Extraction mode for newly inserted data (after the pipe is created):`
`296`	`296`	`-- Whether to extract data in streaming mode (if set to false, batch mode is used).`
	`297`	`+ 'database-name'='testdb.*', -- Scope of Data Synchronization`
`297`	`298`	`'start-time' = '2023.08.23T08:00:00+00:00', -- The event time at which data synchronization starts (inclusive).`
`298`	`299`	`'end-time' = '2023.10.23T08:00:00+00:00' -- The event time at which data synchronization ends (inclusive).`
`299`	`300`	`)`
Original file line number	Diff line number	Diff line change
`@@ -289,6 +289,7 @@ create pipe A2B`
`289`	`289`	`WITH SOURCE (`
`290`	`290`	`'source'= 'iotdb-source',`
`291`	`291`	`'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)`
	`292`	`+ 'path' = 'root.vehicle.**', -- Scope of Data Synchronization`
`292`	`293`	`'start-time' = '2023.08.23T08:00:00+00:00', -- The start event time for synchronizing all data, including start-time`
`293`	`294`	`'end-time' = '2023.10.23T08:00:00+00:00' -- The end event time for synchronizing all data, including end-time`
`294`	`295`	`)`
Original file line number	Diff line number	Diff line change
`@@ -297,6 +297,7 @@ create pipe A2B`
`297`	`297`	`WITH SOURCE (`
`298`	`298`	`'source'= 'iotdb-source',`
`299`	`299`	`'realtime.mode' = 'stream' -- The extraction mode for newly inserted data (after pipe creation)`
	`300`	`+ 'path' = 'root.vehicle.**', -- Scope of Data Synchronization`
`300`	`301`	`'start-time' = '2023.08.23T08:00:00+00:00', -- The start event time for synchronizing all data, including start-time`
`301`	`302`	`'end-time' = '2023.10.23T08:00:00+00:00' -- The end event time for synchronizing all data, including end-time`
`302`	`303`	`)`