add source path in partial data synchronization

leto-bbq · leto-bbq · commit 84fd8ea68694 · 2025-06-10T11:51:52.000+08:00
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/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/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/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
`@@ -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`	`)`
Original file line number	Diff line number	Diff line change
`@@ -290,6 +290,7 @@ create pipe A2B`
`290`	`290`	`WITH SOURCE (`
`291`	`291`	`'source'= 'iotdb-source',`
`292`	`292`	`'realtime.mode' = 'stream' -- 新插入数据（pipe创建后）的抽取模式`
	`293`	`+ 'path' = 'root.vehicle.**', -- 同步数据的范围`
`293`	`294`	`'start-time' = '2023.08.23T08:00:00+00:00', -- 同步所有数据的开始 event time，包含 start-time`
`294`	`295`	`'end-time' = '2023.10.23T08:00:00+00:00' -- 同步所有数据的结束 event time，包含 end-time`
`295`	`296`	`)`
Original file line number	Diff line number	Diff line change
`@@ -298,6 +298,7 @@ create pipe A2B`
`298`	`298`	`WITH SOURCE (`
`299`	`299`	`'source'= 'iotdb-source',`
`300`	`300`	`'realtime.mode' = 'stream' -- 新插入数据（pipe创建后）的抽取模式`
	`301`	`+ 'path' = 'root.vehicle.**', -- 同步数据的范围`
`301`	`302`	`'start-time' = '2023.08.23T08:00:00+00:00', -- 同步所有数据的开始 event time，包含 start-time`
`302`	`303`	`'end-time' = '2023.10.23T08:00:00+00:00' -- 同步所有数据的结束 event time，包含 end-time`
`303`	`304`	`)`