API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Mar 23rd, 2017
87
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 65.28 KB | None | 0 0
raw download clone embed print report
  1. <?xml version="1.0" ?>
  2. <template encoding-version="1.0">
  3. <description></description>
  4. <groupId>faf788c5-015a-1000-f344-de24ceb9d7e7</groupId>
  5. <name>CDC_Replication</name>
  6. <snippet>
  7. <connections>
  8. <id>d21bc8ee-015a-1000-0000-000000000000</id>
  9. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  10. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  11. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  12. <destination>
  13. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  14. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  15. <type>PROCESSOR</type>
  16. </destination>
  17. <flowFileExpiration>0 sec</flowFileExpiration>
  18. <labelIndex>1</labelIndex>
  19. <name></name>
  20. <selectedRelationships>success</selectedRelationships>
  21. <source>
  22. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  23. <id>d21bbe84-015a-1000-0000-000000000000</id>
  24. <type>PROCESSOR</type>
  25. </source>
  26. <zIndex>0</zIndex>
  27. </connections>
  28. <connections>
  29. <id>d2ff5446-015a-1000-0000-000000000000</id>
  30. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  31. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  32. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  33. <destination>
  34. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  35. <id>d2ff3dee-015a-1000-0000-000000000000</id>
  36. <type>PROCESSOR</type>
  37. </destination>
  38. <flowFileExpiration>0 sec</flowFileExpiration>
  39. <labelIndex>1</labelIndex>
  40. <name></name>
  41. <selectedRelationships>begin</selectedRelationships>
  42. <source>
  43. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  44. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  45. <type>PROCESSOR</type>
  46. </source>
  47. <zIndex>0</zIndex>
  48. </connections>
  49. <connections>
  50. <id>d2ffba41-015a-1000-0000-000000000000</id>
  51. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  52. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  53. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  54. <destination>
  55. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  56. <id>d2ff5a58-015a-1000-0000-000000000000</id>
  57. <type>PROCESSOR</type>
  58. </destination>
  59. <flowFileExpiration>0 sec</flowFileExpiration>
  60. <labelIndex>1</labelIndex>
  61. <name></name>
  62. <selectedRelationships>commit</selectedRelationships>
  63. <source>
  64. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  65. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  66. <type>PROCESSOR</type>
  67. </source>
  68. <zIndex>0</zIndex>
  69. </connections>
  70. <connections>
  71. <id>d30d3b96-015a-1000-0000-000000000000</id>
  72. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  73. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  74. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  75. <destination>
  76. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  77. <id>eca7d36a-015a-1000-0000-000000000000</id>
  78. <type>PROCESSOR</type>
  79. </destination>
  80. <flowFileExpiration>0 sec</flowFileExpiration>
  81. <labelIndex>1</labelIndex>
  82. <name></name>
  83. <selectedRelationships>schema change</selectedRelationships>
  84. <source>
  85. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  86. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  87. <type>PROCESSOR</type>
  88. </source>
  89. <zIndex>0</zIndex>
  90. </connections>
  91. <connections>
  92. <id>d30ee5e0-015a-1000-0000-000000000000</id>
  93. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  94. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  95. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  96. <destination>
  97. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  98. <id>d30ed32e-015a-1000-0000-000000000000</id>
  99. <type>FUNNEL</type>
  100. </destination>
  101. <flowFileExpiration>0 sec</flowFileExpiration>
  102. <labelIndex>1</labelIndex>
  103. <name></name>
  104. <selectedRelationships>success</selectedRelationships>
  105. <source>
  106. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  107. <id>d2ff3dee-015a-1000-0000-000000000000</id>
  108. <type>PROCESSOR</type>
  109. </source>
  110. <zIndex>0</zIndex>
  111. </connections>
  112. <connections>
  113. <id>d30f3e6c-015a-1000-0000-000000000000</id>
  114. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  115. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  116. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  117. <destination>
  118. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  119. <id>d30ed32e-015a-1000-0000-000000000000</id>
  120. <type>FUNNEL</type>
  121. </destination>
  122. <flowFileExpiration>0 sec</flowFileExpiration>
  123. <labelIndex>1</labelIndex>
  124. <name></name>
  125. <selectedRelationships>success</selectedRelationships>
  126. <source>
  127. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  128. <id>d2ff5a58-015a-1000-0000-000000000000</id>
  129. <type>PROCESSOR</type>
  130. </source>
  131. <zIndex>0</zIndex>
  132. </connections>
  133. <connections>
  134. <id>d311e7e5-015a-1000-0000-000000000000</id>
  135. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  136. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  137. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  138. <destination>
  139. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  140. <id>d3130a72-015a-1000-0000-000000000000</id>
  141. <type>PROCESSOR</type>
  142. </destination>
  143. <flowFileExpiration>0 sec</flowFileExpiration>
  144. <labelIndex>1</labelIndex>
  145. <name></name>
  146. <prioritizers>org.apache.nifi.prioritizer.PriorityAttributePrioritizer</prioritizers>
  147. <source>
  148. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  149. <id>d30ed32e-015a-1000-0000-000000000000</id>
  150. <type>FUNNEL</type>
  151. </source>
  152. <zIndex>0</zIndex>
  153. </connections>
  154. <connections>
  155. <id>d3132b5e-015a-1000-0000-000000000000</id>
  156. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  157. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  158. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  159. <destination>
  160. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  161. <id>d311d75d-015a-1000-0000-000000000000</id>
  162. <type>PROCESSOR</type>
  163. </destination>
  164. <flowFileExpiration>0 sec</flowFileExpiration>
  165. <labelIndex>1</labelIndex>
  166. <name></name>
  167. <selectedRelationships>success</selectedRelationships>
  168. <source>
  169. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  170. <id>d3130a72-015a-1000-0000-000000000000</id>
  171. <type>PROCESSOR</type>
  172. </source>
  173. <zIndex>0</zIndex>
  174. </connections>
  175. <connections>
  176. <id>ec8df056-015a-1000-0000-000000000000</id>
  177. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  178. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  179. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  180. <destination>
  181. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  182. <id>fbbffda6-015a-1000-0000-000000000000</id>
  183. <type>PROCESSOR</type>
  184. </destination>
  185. <flowFileExpiration>0 sec</flowFileExpiration>
  186. <labelIndex>1</labelIndex>
  187. <name></name>
  188. <selectedRelationships>success</selectedRelationships>
  189. <source>
  190. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  191. <id>d30c1bbc-015a-1000-0000-000000000000</id>
  192. <type>PROCESSOR</type>
  193. </source>
  194. <zIndex>0</zIndex>
  195. </connections>
  196. <connections>
  197. <id>ec8e459f-015a-1000-0000-000000000000</id>
  198. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  199. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  200. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  201. <destination>
  202. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  203. <id>d30ed32e-015a-1000-0000-000000000000</id>
  204. <type>FUNNEL</type>
  205. </destination>
  206. <flowFileExpiration>0 sec</flowFileExpiration>
  207. <labelIndex>1</labelIndex>
  208. <name></name>
  209. <selectedRelationships>sql</selectedRelationships>
  210. <source>
  211. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  212. <id>ec8ddd6c-015a-1000-0000-000000000000</id>
  213. <type>PROCESSOR</type>
  214. </source>
  215. <zIndex>0</zIndex>
  216. </connections>
  217. <connections>
  218. <id>eca23ae2-015a-1000-0000-000000000000</id>
  219. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  220. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  221. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  222. <destination>
  223. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  224. <id>d30c1bbc-015a-1000-0000-000000000000</id>
  225. <type>PROCESSOR</type>
  226. </destination>
  227. <flowFileExpiration>0 sec</flowFileExpiration>
  228. <labelIndex>1</labelIndex>
  229. <name></name>
  230. <selectedRelationships>matched</selectedRelationships>
  231. <source>
  232. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  233. <id>eca06560-015a-1000-0000-000000000000</id>
  234. <type>PROCESSOR</type>
  235. </source>
  236. <zIndex>0</zIndex>
  237. </connections>
  238. <connections>
  239. <id>eca59de7-015a-1000-0000-000000000000</id>
  240. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  241. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  242. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  243. <destination>
  244. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  245. <id>eca06560-015a-1000-0000-000000000000</id>
  246. <type>PROCESSOR</type>
  247. </destination>
  248. <flowFileExpiration>0 sec</flowFileExpiration>
  249. <labelIndex>1</labelIndex>
  250. <name></name>
  251. <selectedRelationships>delete</selectedRelationships>
  252. <selectedRelationships>insert</selectedRelationships>
  253. <selectedRelationships>update</selectedRelationships>
  254. <source>
  255. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  256. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  257. <type>PROCESSOR</type>
  258. </source>
  259. <zIndex>0</zIndex>
  260. </connections>
  261. <connections>
  262. <id>eca8444e-015a-1000-0000-000000000000</id>
  263. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  264. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  265. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  266. <destination>
  267. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  268. <id>d30ed32e-015a-1000-0000-000000000000</id>
  269. <type>FUNNEL</type>
  270. </destination>
  271. <flowFileExpiration>0 sec</flowFileExpiration>
  272. <labelIndex>1</labelIndex>
  273. <name></name>
  274. <selectedRelationships>matched</selectedRelationships>
  275. <source>
  276. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  277. <id>eca7d36a-015a-1000-0000-000000000000</id>
  278. <type>PROCESSOR</type>
  279. </source>
  280. <zIndex>0</zIndex>
  281. </connections>
  282. <connections>
  283. <id>fbc041d6-015a-1000-0000-000000000000</id>
  284. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  285. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  286. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  287. <destination>
  288. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  289. <id>ec8ddd6c-015a-1000-0000-000000000000</id>
  290. <type>PROCESSOR</type>
  291. </destination>
  292. <flowFileExpiration>0 sec</flowFileExpiration>
  293. <labelIndex>1</labelIndex>
  294. <name></name>
  295. <selectedRelationships>insert</selectedRelationships>
  296. <source>
  297. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  298. <id>fbbffda6-015a-1000-0000-000000000000</id>
  299. <type>PROCESSOR</type>
  300. </source>
  301. <zIndex>0</zIndex>
  302. </connections>
  303. <connections>
  304. <id>fbc098bd-015a-1000-0000-000000000000</id>
  305. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  306. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  307. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  308. <destination>
  309. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  310. <id>fbc0555b-015a-1000-0000-000000000000</id>
  311. <type>PROCESSOR</type>
  312. </destination>
  313. <flowFileExpiration>0 sec</flowFileExpiration>
  314. <labelIndex>1</labelIndex>
  315. <name></name>
  316. <selectedRelationships>update</selectedRelationships>
  317. <source>
  318. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  319. <id>fbbffda6-015a-1000-0000-000000000000</id>
  320. <type>PROCESSOR</type>
  321. </source>
  322. <zIndex>0</zIndex>
  323. </connections>
  324. <connections>
  325. <id>fbc0afbe-015a-1000-0000-000000000000</id>
  326. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  327. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  328. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  329. <destination>
  330. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  331. <id>d30ed32e-015a-1000-0000-000000000000</id>
  332. <type>FUNNEL</type>
  333. </destination>
  334. <flowFileExpiration>0 sec</flowFileExpiration>
  335. <labelIndex>1</labelIndex>
  336. <name></name>
  337. <selectedRelationships>sql</selectedRelationships>
  338. <source>
  339. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  340. <id>fbc0555b-015a-1000-0000-000000000000</id>
  341. <type>PROCESSOR</type>
  342. </source>
  343. <zIndex>0</zIndex>
  344. </connections>
  345. <connections>
  346. <id>fbc0eaa6-015a-1000-0000-000000000000</id>
  347. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  348. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  349. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  350. <destination>
  351. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  352. <id>fbc0c003-015a-1000-0000-000000000000</id>
  353. <type>PROCESSOR</type>
  354. </destination>
  355. <flowFileExpiration>0 sec</flowFileExpiration>
  356. <labelIndex>1</labelIndex>
  357. <name></name>
  358. <selectedRelationships>delete</selectedRelationships>
  359. <source>
  360. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  361. <id>fbbffda6-015a-1000-0000-000000000000</id>
  362. <type>PROCESSOR</type>
  363. </source>
  364. <zIndex>0</zIndex>
  365. </connections>
  366. <connections>
  367. <id>fbc12d44-015a-1000-0000-000000000000</id>
  368. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  369. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  370. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  371. <destination>
  372. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  373. <id>d30ed32e-015a-1000-0000-000000000000</id>
  374. <type>FUNNEL</type>
  375. </destination>
  376. <flowFileExpiration>0 sec</flowFileExpiration>
  377. <labelIndex>1</labelIndex>
  378. <name></name>
  379. <selectedRelationships>sql</selectedRelationships>
  380. <source>
  381. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  382. <id>fbc0c003-015a-1000-0000-000000000000</id>
  383. <type>PROCESSOR</type>
  384. </source>
  385. <zIndex>0</zIndex>
  386. </connections>
  387. <connections>
  388. <id>fcf0bd17-015a-1000-0000-000000000000</id>
  389. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  390. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  391. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  392. <destination>
  393. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  394. <id>fcf0f3e8-015a-1000-0000-000000000000</id>
  395. <type>FUNNEL</type>
  396. </destination>
  397. <flowFileExpiration>0 sec</flowFileExpiration>
  398. <labelIndex>1</labelIndex>
  399. <name></name>
  400. <selectedRelationships>failure</selectedRelationships>
  401. <source>
  402. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  403. <id>ec8ddd6c-015a-1000-0000-000000000000</id>
  404. <type>PROCESSOR</type>
  405. </source>
  406. <zIndex>0</zIndex>
  407. </connections>
  408. <connections>
  409. <id>fcf0d267-015a-1000-0000-000000000000</id>
  410. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  411. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  412. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  413. <destination>
  414. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  415. <id>fcf0f3e8-015a-1000-0000-000000000000</id>
  416. <type>FUNNEL</type>
  417. </destination>
  418. <flowFileExpiration>0 sec</flowFileExpiration>
  419. <labelIndex>1</labelIndex>
  420. <name></name>
  421. <selectedRelationships>failure</selectedRelationships>
  422. <source>
  423. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  424. <id>fbc0555b-015a-1000-0000-000000000000</id>
  425. <type>PROCESSOR</type>
  426. </source>
  427. <zIndex>0</zIndex>
  428. </connections>
  429. <connections>
  430. <id>fcf0e541-015a-1000-0000-000000000000</id>
  431. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  432. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  433. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  434. <destination>
  435. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  436. <id>fcf0f3e8-015a-1000-0000-000000000000</id>
  437. <type>FUNNEL</type>
  438. </destination>
  439. <flowFileExpiration>0 sec</flowFileExpiration>
  440. <labelIndex>1</labelIndex>
  441. <name></name>
  442. <selectedRelationships>failure</selectedRelationships>
  443. <source>
  444. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  445. <id>fbc0c003-015a-1000-0000-000000000000</id>
  446. <type>PROCESSOR</type>
  447. </source>
  448. <zIndex>0</zIndex>
  449. </connections>
  450. <connections>
  451. <id>fcf119e7-015a-1000-0000-000000000000</id>
  452. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  453. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  454. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  455. <destination>
  456. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  457. <id>d311d75d-015a-1000-0000-000000000000</id>
  458. <type>PROCESSOR</type>
  459. </destination>
  460. <flowFileExpiration>0 sec</flowFileExpiration>
  461. <labelIndex>1</labelIndex>
  462. <name></name>
  463. <source>
  464. <groupId>faf788c5-015a-1000-0000-000000000000</groupId>
  465. <id>fcf0f3e8-015a-1000-0000-000000000000</id>
  466. <type>FUNNEL</type>
  467. </source>
  468. <zIndex>0</zIndex>
  469. </connections>
  470. <controllerServices>
  471. <id>ba141911-015a-1000-0000-000000000000</id>
  472. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  473. <comments></comments>
  474. <descriptors>
  475. <entry>
  476. <key>Server Hostname</key>
  477. <value>
  478. <name>Server Hostname</name>
  479. </value>
  480. </entry>
  481. <entry>
  482. <key>Server Port</key>
  483. <value>
  484. <name>Server Port</name>
  485. </value>
  486. </entry>
  487. <entry>
  488. <key>SSL Context Service</key>
  489. <value>
  490. <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService>
  491. <name>SSL Context Service</name>
  492. </value>
  493. </entry>
  494. <entry>
  495. <key>Communications Timeout</key>
  496. <value>
  497. <name>Communications Timeout</name>
  498. </value>
  499. </entry>
  500. </descriptors>
  501. <name>DistributedMapCacheClientService</name>
  502. <properties>
  503. <entry>
  504. <key>Server Hostname</key>
  505. <value>localhost</value>
  506. </entry>
  507. <entry>
  508. <key>Server Port</key>
  509. <value>4557</value>
  510. </entry>
  511. <entry>
  512. <key>SSL Context Service</key>
  513. </entry>
  514. <entry>
  515. <key>Communications Timeout</key>
  516. <value>30 secs</value>
  517. </entry>
  518. </properties>
  519. <state>ENABLED</state>
  520. <type>org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService</type>
  521. </controllerServices>
  522. <controllerServices>
  523. <id>d3095cea-015a-1000-0000-000000000000</id>
  524. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  525. <comments></comments>
  526. <descriptors>
  527. <entry>
  528. <key>Database Connection URL</key>
  529. <value>
  530. <name>Database Connection URL</name>
  531. </value>
  532. </entry>
  533. <entry>
  534. <key>Database Driver Class Name</key>
  535. <value>
  536. <name>Database Driver Class Name</name>
  537. </value>
  538. </entry>
  539. <entry>
  540. <key>database-driver-locations</key>
  541. <value>
  542. <name>database-driver-locations</name>
  543. </value>
  544. </entry>
  545. <entry>
  546. <key>Database User</key>
  547. <value>
  548. <name>Database User</name>
  549. </value>
  550. </entry>
  551. <entry>
  552. <key>Password</key>
  553. <value>
  554. <name>Password</name>
  555. </value>
  556. </entry>
  557. <entry>
  558. <key>Max Wait Time</key>
  559. <value>
  560. <name>Max Wait Time</name>
  561. </value>
  562. </entry>
  563. <entry>
  564. <key>Max Total Connections</key>
  565. <value>
  566. <name>Max Total Connections</name>
  567. </value>
  568. </entry>
  569. <entry>
  570. <key>Validation-query</key>
  571. <value>
  572. <name>Validation-query</name>
  573. </value>
  574. </entry>
  575. </descriptors>
  576. <name>MySQL CDC Backup</name>
  577. <properties>
  578. <entry>
  579. <key>Database Connection URL</key>
  580. <value>jdbc:mysql://192.168.99.100:32768/cdc_backup</value>
  581. </entry>
  582. <entry>
  583. <key>Database Driver Class Name</key>
  584. <value>com.mysql.jdbc.Driver</value>
  585. </entry>
  586. <entry>
  587. <key>database-driver-locations</key>
  588. <value>file:///Users/mburgess/jdbc_drivers/mysql-connector-java-5.1.38-bin.jar</value>
  589. </entry>
  590. <entry>
  591. <key>Database User</key>
  592. <value>root</value>
  593. </entry>
  594. <entry>
  595. <key>Password</key>
  596. </entry>
  597. <entry>
  598. <key>Max Wait Time</key>
  599. <value>500 millis</value>
  600. </entry>
  601. <entry>
  602. <key>Max Total Connections</key>
  603. <value>8</value>
  604. </entry>
  605. <entry>
  606. <key>Validation-query</key>
  607. </entry>
  608. </properties>
  609. <state>ENABLED</state>
  610. <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
  611. </controllerServices>
  612. <funnels>
  613. <id>d30ed32e-015a-1000-0000-000000000000</id>
  614. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  615. <position>
  616. <x>1386.873438296021</x>
  617. <y>692.1651199508015</y>
  618. </position>
  619. </funnels>
  620. <funnels>
  621. <id>fcf0f3e8-015a-1000-0000-000000000000</id>
  622. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  623. <position>
  624. <x>1934.2057900162977</x>
  625. <y>658.9592282837363</y>
  626. </position>
  627. </funnels>
  628. <processors>
  629. <id>d21bbe84-015a-1000-0000-000000000000</id>
  630. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  631. <position>
  632. <x>0.0</x>
  633. <y>94.97420536290088</y>
  634. </position>
  635. <config>
  636. <bulletinLevel>WARN</bulletinLevel>
  637. <comments></comments>
  638. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  639. <descriptors>
  640. <entry>
  641. <key>get-cdc-mysql-hosts</key>
  642. <value>
  643. <name>get-cdc-mysql-hosts</name>
  644. </value>
  645. </entry>
  646. <entry>
  647. <key>get-cdc-mysql-driver-class</key>
  648. <value>
  649. <name>get-cdc-mysql-driver-class</name>
  650. </value>
  651. </entry>
  652. <entry>
  653. <key>get-cdc-mysql-driver-locations</key>
  654. <value>
  655. <name>get-cdc-mysql-driver-locations</name>
  656. </value>
  657. </entry>
  658. <entry>
  659. <key>Username</key>
  660. <value>
  661. <name>Username</name>
  662. </value>
  663. </entry>
  664. <entry>
  665. <key>Password</key>
  666. <value>
  667. <name>Password</name>
  668. </value>
  669. </entry>
  670. <entry>
  671. <key>get-cdc-mysql-db-name-pattern</key>
  672. <value>
  673. <name>get-cdc-mysql-db-name-pattern</name>
  674. </value>
  675. </entry>
  676. <entry>
  677. <key>get-cdc-mysql-name-pattern</key>
  678. <value>
  679. <name>get-cdc-mysql-name-pattern</name>
  680. </value>
  681. </entry>
  682. <entry>
  683. <key>get-cdc-mysql-max-wait-time</key>
  684. <value>
  685. <name>get-cdc-mysql-max-wait-time</name>
  686. </value>
  687. </entry>
  688. <entry>
  689. <key>get-cdc-mysql-dist-map-cache-client</key>
  690. <value>
  691. <identifiesControllerService>org.apache.nifi.distributed.cache.client.DistributedMapCacheClient</identifiesControllerService>
  692. <name>get-cdc-mysql-dist-map-cache-client</name>
  693. </value>
  694. </entry>
  695. <entry>
  696. <key>get-cdc-mysql-retrieve-all-records</key>
  697. <value>
  698. <name>get-cdc-mysql-retrieve-all-records</name>
  699. </value>
  700. </entry>
  701. <entry>
  702. <key>get-cdc-mysql-init-seq-id</key>
  703. <value>
  704. <name>get-cdc-mysql-init-seq-id</name>
  705. </value>
  706. </entry>
  707. </descriptors>
  708. <executionNode>ALL</executionNode>
  709. <lossTolerant>false</lossTolerant>
  710. <penaltyDuration>30 sec</penaltyDuration>
  711. <properties>
  712. <entry>
  713. <key>get-cdc-mysql-hosts</key>
  714. <value>192.168.99.100:32768</value>
  715. </entry>
  716. <entry>
  717. <key>get-cdc-mysql-driver-class</key>
  718. <value>com.mysql.jdbc.Driver</value>
  719. </entry>
  720. <entry>
  721. <key>get-cdc-mysql-driver-locations</key>
  722. <value>/Users/mburgess/jdbc_drivers/mysql-connector-java-5.1.38-bin.jar</value>
  723. </entry>
  724. <entry>
  725. <key>Username</key>
  726. <value>root</value>
  727. </entry>
  728. <entry>
  729. <key>Password</key>
  730. </entry>
  731. <entry>
  732. <key>get-cdc-mysql-db-name-pattern</key>
  733. </entry>
  734. <entry>
  735. <key>get-cdc-mysql-name-pattern</key>
  736. <value>j1</value>
  737. </entry>
  738. <entry>
  739. <key>get-cdc-mysql-max-wait-time</key>
  740. <value>4 seconds</value>
  741. </entry>
  742. <entry>
  743. <key>get-cdc-mysql-dist-map-cache-client</key>
  744. <value>ba141911-015a-1000-0000-000000000000</value>
  745. </entry>
  746. <entry>
  747. <key>get-cdc-mysql-retrieve-all-records</key>
  748. <value>true</value>
  749. </entry>
  750. <entry>
  751. <key>get-cdc-mysql-init-seq-id</key>
  752. </entry>
  753. </properties>
  754. <runDurationMillis>0</runDurationMillis>
  755. <schedulingPeriod>200 millis</schedulingPeriod>
  756. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  757. <yieldDuration>1 sec</yieldDuration>
  758. </config>
  759. <name>GetChangeDataCaptureMySQL</name>
  760. <relationships>
  761. <autoTerminate>false</autoTerminate>
  762. <name>success</name>
  763. </relationships>
  764. <style>
  765. <entry>
  766. <key>background-color</key>
  767. <value>#71f771</value>
  768. </entry>
  769. </style>
  770. <type>org.apache.nifi.processors.standard.GetChangeDataCaptureMySQL</type>
  771. </processors>
  772. <processors>
  773. <id>d2fd3d9e-015a-1000-0000-000000000000</id>
  774. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  775. <position>
  776. <x>0.8199107972299089</x>
  777. <y>414.0</y>
  778. </position>
  779. <config>
  780. <bulletinLevel>WARN</bulletinLevel>
  781. <comments></comments>
  782. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  783. <descriptors>
  784. <entry>
  785. <key>Routing Strategy</key>
  786. <value>
  787. <name>Routing Strategy</name>
  788. </value>
  789. </entry>
  790. <entry>
  791. <key>begin</key>
  792. <value>
  793. <name>begin</name>
  794. </value>
  795. </entry>
  796. <entry>
  797. <key>commit</key>
  798. <value>
  799. <name>commit</name>
  800. </value>
  801. </entry>
  802. <entry>
  803. <key>delete</key>
  804. <value>
  805. <name>delete</name>
  806. </value>
  807. </entry>
  808. <entry>
  809. <key>insert</key>
  810. <value>
  811. <name>insert</name>
  812. </value>
  813. </entry>
  814. <entry>
  815. <key>schema change</key>
  816. <value>
  817. <name>schema change</name>
  818. </value>
  819. </entry>
  820. <entry>
  821. <key>update</key>
  822. <value>
  823. <name>update</name>
  824. </value>
  825. </entry>
  826. </descriptors>
  827. <executionNode>ALL</executionNode>
  828. <lossTolerant>false</lossTolerant>
  829. <penaltyDuration>30 sec</penaltyDuration>
  830. <properties>
  831. <entry>
  832. <key>Routing Strategy</key>
  833. <value>Route to Property name</value>
  834. </entry>
  835. <entry>
  836. <key>begin</key>
  837. <value>${cdc.event.type:equals('begin')}</value>
  838. </entry>
  839. <entry>
  840. <key>commit</key>
  841. <value>${cdc.event.type:equals('commit')}</value>
  842. </entry>
  843. <entry>
  844. <key>delete</key>
  845. <value>${cdc.event.type:equals('delete')}</value>
  846. </entry>
  847. <entry>
  848. <key>insert</key>
  849. <value>${cdc.event.type:equals('write')}</value>
  850. </entry>
  851. <entry>
  852. <key>schema change</key>
  853. <value>${cdc.event.type:equals('schema_change')}</value>
  854. </entry>
  855. <entry>
  856. <key>update</key>
  857. <value>${cdc.event.type:equals('update')}</value>
  858. </entry>
  859. </properties>
  860. <runDurationMillis>0</runDurationMillis>
  861. <schedulingPeriod>0 sec</schedulingPeriod>
  862. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  863. <yieldDuration>1 sec</yieldDuration>
  864. </config>
  865. <name>RouteOnAttribute</name>
  866. <relationships>
  867. <autoTerminate>false</autoTerminate>
  868. <name>begin</name>
  869. </relationships>
  870. <relationships>
  871. <autoTerminate>false</autoTerminate>
  872. <name>commit</name>
  873. </relationships>
  874. <relationships>
  875. <autoTerminate>false</autoTerminate>
  876. <name>delete</name>
  877. </relationships>
  878. <relationships>
  879. <autoTerminate>false</autoTerminate>
  880. <name>insert</name>
  881. </relationships>
  882. <relationships>
  883. <autoTerminate>false</autoTerminate>
  884. <name>schema change</name>
  885. </relationships>
  886. <relationships>
  887. <autoTerminate>true</autoTerminate>
  888. <name>unmatched</name>
  889. </relationships>
  890. <relationships>
  891. <autoTerminate>false</autoTerminate>
  892. <name>update</name>
  893. </relationships>
  894. <style></style>
  895. <type>org.apache.nifi.processors.standard.RouteOnAttribute</type>
  896. </processors>
  897. <processors>
  898. <id>d2ff3dee-015a-1000-0000-000000000000</id>
  899. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  900. <position>
  901. <x>554.9789451199856</x>
  902. <y>645.8972561184496</y>
  903. </position>
  904. <config>
  905. <bulletinLevel>WARN</bulletinLevel>
  906. <comments></comments>
  907. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  908. <descriptors>
  909. <entry>
  910. <key>Regular Expression</key>
  911. <value>
  912. <name>Regular Expression</name>
  913. </value>
  914. </entry>
  915. <entry>
  916. <key>Replacement Value</key>
  917. <value>
  918. <name>Replacement Value</name>
  919. </value>
  920. </entry>
  921. <entry>
  922. <key>Character Set</key>
  923. <value>
  924. <name>Character Set</name>
  925. </value>
  926. </entry>
  927. <entry>
  928. <key>Maximum Buffer Size</key>
  929. <value>
  930. <name>Maximum Buffer Size</name>
  931. </value>
  932. </entry>
  933. <entry>
  934. <key>Replacement Strategy</key>
  935. <value>
  936. <name>Replacement Strategy</name>
  937. </value>
  938. </entry>
  939. <entry>
  940. <key>Evaluation Mode</key>
  941. <value>
  942. <name>Evaluation Mode</name>
  943. </value>
  944. </entry>
  945. </descriptors>
  946. <executionNode>ALL</executionNode>
  947. <lossTolerant>false</lossTolerant>
  948. <penaltyDuration>30 sec</penaltyDuration>
  949. <properties>
  950. <entry>
  951. <key>Regular Expression</key>
  952. <value>(?s)(^.*$)</value>
  953. </entry>
  954. <entry>
  955. <key>Replacement Value</key>
  956. <value>BEGIN</value>
  957. </entry>
  958. <entry>
  959. <key>Character Set</key>
  960. <value>UTF-8</value>
  961. </entry>
  962. <entry>
  963. <key>Maximum Buffer Size</key>
  964. <value>1 MB</value>
  965. </entry>
  966. <entry>
  967. <key>Replacement Strategy</key>
  968. <value>Regex Replace</value>
  969. </entry>
  970. <entry>
  971. <key>Evaluation Mode</key>
  972. <value>Entire text</value>
  973. </entry>
  974. </properties>
  975. <runDurationMillis>0</runDurationMillis>
  976. <schedulingPeriod>0 sec</schedulingPeriod>
  977. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  978. <yieldDuration>1 sec</yieldDuration>
  979. </config>
  980. <name>Replace With BEGIN</name>
  981. <relationships>
  982. <autoTerminate>true</autoTerminate>
  983. <name>failure</name>
  984. </relationships>
  985. <relationships>
  986. <autoTerminate>false</autoTerminate>
  987. <name>success</name>
  988. </relationships>
  989. <style></style>
  990. <type>org.apache.nifi.processors.standard.ReplaceText</type>
  991. </processors>
  992. <processors>
  993. <id>d2ff5a58-015a-1000-0000-000000000000</id>
  994. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  995. <position>
  996. <x>559.3269065457669</x>
  997. <y>454.99497340360585</y>
  998. </position>
  999. <config>
  1000. <bulletinLevel>WARN</bulletinLevel>
  1001. <comments></comments>
  1002. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1003. <descriptors>
  1004. <entry>
  1005. <key>Regular Expression</key>
  1006. <value>
  1007. <name>Regular Expression</name>
  1008. </value>
  1009. </entry>
  1010. <entry>
  1011. <key>Replacement Value</key>
  1012. <value>
  1013. <name>Replacement Value</name>
  1014. </value>
  1015. </entry>
  1016. <entry>
  1017. <key>Character Set</key>
  1018. <value>
  1019. <name>Character Set</name>
  1020. </value>
  1021. </entry>
  1022. <entry>
  1023. <key>Maximum Buffer Size</key>
  1024. <value>
  1025. <name>Maximum Buffer Size</name>
  1026. </value>
  1027. </entry>
  1028. <entry>
  1029. <key>Replacement Strategy</key>
  1030. <value>
  1031. <name>Replacement Strategy</name>
  1032. </value>
  1033. </entry>
  1034. <entry>
  1035. <key>Evaluation Mode</key>
  1036. <value>
  1037. <name>Evaluation Mode</name>
  1038. </value>
  1039. </entry>
  1040. </descriptors>
  1041. <executionNode>ALL</executionNode>
  1042. <lossTolerant>false</lossTolerant>
  1043. <penaltyDuration>30 sec</penaltyDuration>
  1044. <properties>
  1045. <entry>
  1046. <key>Regular Expression</key>
  1047. <value>(?s)(^.*$)</value>
  1048. </entry>
  1049. <entry>
  1050. <key>Replacement Value</key>
  1051. <value>COMMIT</value>
  1052. </entry>
  1053. <entry>
  1054. <key>Character Set</key>
  1055. <value>UTF-8</value>
  1056. </entry>
  1057. <entry>
  1058. <key>Maximum Buffer Size</key>
  1059. <value>1 MB</value>
  1060. </entry>
  1061. <entry>
  1062. <key>Replacement Strategy</key>
  1063. <value>Regex Replace</value>
  1064. </entry>
  1065. <entry>
  1066. <key>Evaluation Mode</key>
  1067. <value>Entire text</value>
  1068. </entry>
  1069. </properties>
  1070. <runDurationMillis>0</runDurationMillis>
  1071. <schedulingPeriod>0 sec</schedulingPeriod>
  1072. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1073. <yieldDuration>1 sec</yieldDuration>
  1074. </config>
  1075. <name>Replace With COMMIT</name>
  1076. <relationships>
  1077. <autoTerminate>true</autoTerminate>
  1078. <name>failure</name>
  1079. </relationships>
  1080. <relationships>
  1081. <autoTerminate>false</autoTerminate>
  1082. <name>success</name>
  1083. </relationships>
  1084. <style></style>
  1085. <type>org.apache.nifi.processors.standard.ReplaceText</type>
  1086. </processors>
  1087. <processors>
  1088. <id>d30c1bbc-015a-1000-0000-000000000000</id>
  1089. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1090. <position>
  1091. <x>981.5541156734657</x>
  1092. <y>2.0024317251973116</y>
  1093. </position>
  1094. <config>
  1095. <bulletinLevel>WARN</bulletinLevel>
  1096. <comments></comments>
  1097. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1098. <descriptors>
  1099. <entry>
  1100. <key>jolt-transform</key>
  1101. <value>
  1102. <name>jolt-transform</name>
  1103. </value>
  1104. </entry>
  1105. <entry>
  1106. <key>jolt-custom-class</key>
  1107. <value>
  1108. <name>jolt-custom-class</name>
  1109. </value>
  1110. </entry>
  1111. <entry>
  1112. <key>jolt-custom-modules</key>
  1113. <value>
  1114. <name>jolt-custom-modules</name>
  1115. </value>
  1116. </entry>
  1117. <entry>
  1118. <key>jolt-spec</key>
  1119. <value>
  1120. <name>jolt-spec</name>
  1121. </value>
  1122. </entry>
  1123. </descriptors>
  1124. <executionNode>ALL</executionNode>
  1125. <lossTolerant>false</lossTolerant>
  1126. <penaltyDuration>30 sec</penaltyDuration>
  1127. <properties>
  1128. <entry>
  1129. <key>jolt-transform</key>
  1130. <value>jolt-transform-chain</value>
  1131. </entry>
  1132. <entry>
  1133. <key>jolt-custom-class</key>
  1134. </entry>
  1135. <entry>
  1136. <key>jolt-custom-modules</key>
  1137. </entry>
  1138. <entry>
  1139. <key>jolt-spec</key>
  1140. <value>[
  1141. {
  1142. "operation": "shift",
  1143. "spec": {
  1144. "columns": {
  1145. "*": {
  1146. "@(value)": "[#1].@(1,name)"
  1147. }
  1148. }
  1149. }
  1150. }
  1151. ]</value>
  1152. </entry>
  1153. </properties>
  1154. <runDurationMillis>0</runDurationMillis>
  1155. <schedulingPeriod>0 sec</schedulingPeriod>
  1156. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1157. <yieldDuration>1 sec</yieldDuration>
  1158. </config>
  1159. <name>Transform to Flat JSON</name>
  1160. <relationships>
  1161. <autoTerminate>true</autoTerminate>
  1162. <name>failure</name>
  1163. </relationships>
  1164. <relationships>
  1165. <autoTerminate>false</autoTerminate>
  1166. <name>success</name>
  1167. </relationships>
  1168. <style></style>
  1169. <type>org.apache.nifi.processors.standard.JoltTransformJSON</type>
  1170. </processors>
  1171. <processors>
  1172. <id>d311d75d-015a-1000-0000-000000000000</id>
  1173. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1174. <position>
  1175. <x>1794.6361226471308</x>
  1176. <y>805.068554079779</y>
  1177. </position>
  1178. <config>
  1179. <bulletinLevel>WARN</bulletinLevel>
  1180. <comments></comments>
  1181. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1182. <descriptors>
  1183. <entry>
  1184. <key>Log Level</key>
  1185. <value>
  1186. <name>Log Level</name>
  1187. </value>
  1188. </entry>
  1189. <entry>
  1190. <key>Log Payload</key>
  1191. <value>
  1192. <name>Log Payload</name>
  1193. </value>
  1194. </entry>
  1195. <entry>
  1196. <key>Attributes to Log</key>
  1197. <value>
  1198. <name>Attributes to Log</name>
  1199. </value>
  1200. </entry>
  1201. <entry>
  1202. <key>Attributes to Ignore</key>
  1203. <value>
  1204. <name>Attributes to Ignore</name>
  1205. </value>
  1206. </entry>
  1207. <entry>
  1208. <key>Log prefix</key>
  1209. <value>
  1210. <name>Log prefix</name>
  1211. </value>
  1212. </entry>
  1213. </descriptors>
  1214. <executionNode>ALL</executionNode>
  1215. <lossTolerant>false</lossTolerant>
  1216. <penaltyDuration>30 sec</penaltyDuration>
  1217. <properties>
  1218. <entry>
  1219. <key>Log Level</key>
  1220. <value>info</value>
  1221. </entry>
  1222. <entry>
  1223. <key>Log Payload</key>
  1224. <value>false</value>
  1225. </entry>
  1226. <entry>
  1227. <key>Attributes to Log</key>
  1228. </entry>
  1229. <entry>
  1230. <key>Attributes to Ignore</key>
  1231. </entry>
  1232. <entry>
  1233. <key>Log prefix</key>
  1234. </entry>
  1235. </properties>
  1236. <runDurationMillis>0</runDurationMillis>
  1237. <schedulingPeriod>0 sec</schedulingPeriod>
  1238. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1239. <yieldDuration>1 sec</yieldDuration>
  1240. </config>
  1241. <name>LogAttribute</name>
  1242. <relationships>
  1243. <autoTerminate>false</autoTerminate>
  1244. <name>success</name>
  1245. </relationships>
  1246. <style></style>
  1247. <type>org.apache.nifi.processors.standard.LogAttribute</type>
  1248. </processors>
  1249. <processors>
  1250. <id>d3130a72-015a-1000-0000-000000000000</id>
  1251. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1252. <position>
  1253. <x>1236.998705329768</x>
  1254. <y>806.5159878169598</y>
  1255. </position>
  1256. <config>
  1257. <bulletinLevel>WARN</bulletinLevel>
  1258. <comments></comments>
  1259. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1260. <descriptors>
  1261. <entry>
  1262. <key>Delete Attributes Expression</key>
  1263. <value>
  1264. <name>Delete Attributes Expression</name>
  1265. </value>
  1266. </entry>
  1267. <entry>
  1268. <key>Store State</key>
  1269. <value>
  1270. <name>Store State</name>
  1271. </value>
  1272. </entry>
  1273. <entry>
  1274. <key>Stateful Variables Initial Value</key>
  1275. <value>
  1276. <name>Stateful Variables Initial Value</name>
  1277. </value>
  1278. </entry>
  1279. <entry>
  1280. <key>priority</key>
  1281. <value>
  1282. <name>priority</name>
  1283. </value>
  1284. </entry>
  1285. </descriptors>
  1286. <executionNode>ALL</executionNode>
  1287. <lossTolerant>false</lossTolerant>
  1288. <penaltyDuration>30 sec</penaltyDuration>
  1289. <properties>
  1290. <entry>
  1291. <key>Delete Attributes Expression</key>
  1292. </entry>
  1293. <entry>
  1294. <key>Store State</key>
  1295. <value>Do not store state</value>
  1296. </entry>
  1297. <entry>
  1298. <key>Stateful Variables Initial Value</key>
  1299. </entry>
  1300. <entry>
  1301. <key>priority</key>
  1302. <value>${cdc.sequence.id}</value>
  1303. </entry>
  1304. </properties>
  1305. <runDurationMillis>0</runDurationMillis>
  1306. <schedulingPeriod>0 sec</schedulingPeriod>
  1307. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1308. <yieldDuration>1 sec</yieldDuration>
  1309. </config>
  1310. <name>Set Priority attribute</name>
  1311. <relationships>
  1312. <autoTerminate>false</autoTerminate>
  1313. <name>success</name>
  1314. </relationships>
  1315. <style></style>
  1316. <type>org.apache.nifi.processors.attributes.UpdateAttribute</type>
  1317. </processors>
  1318. <processors>
  1319. <id>ec8ddd6c-015a-1000-0000-000000000000</id>
  1320. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1321. <position>
  1322. <x>1007.8860662491472</x>
  1323. <y>248.69908718598026</y>
  1324. </position>
  1325. <config>
  1326. <bulletinLevel>WARN</bulletinLevel>
  1327. <comments></comments>
  1328. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1329. <descriptors>
  1330. <entry>
  1331. <key>JDBC Connection Pool</key>
  1332. <value>
  1333. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  1334. <name>JDBC Connection Pool</name>
  1335. </value>
  1336. </entry>
  1337. <entry>
  1338. <key>Statement Type</key>
  1339. <value>
  1340. <name>Statement Type</name>
  1341. </value>
  1342. </entry>
  1343. <entry>
  1344. <key>Table Name</key>
  1345. <value>
  1346. <name>Table Name</name>
  1347. </value>
  1348. </entry>
  1349. <entry>
  1350. <key>Catalog Name</key>
  1351. <value>
  1352. <name>Catalog Name</name>
  1353. </value>
  1354. </entry>
  1355. <entry>
  1356. <key>Schema Name</key>
  1357. <value>
  1358. <name>Schema Name</name>
  1359. </value>
  1360. </entry>
  1361. <entry>
  1362. <key>Translate Field Names</key>
  1363. <value>
  1364. <name>Translate Field Names</name>
  1365. </value>
  1366. </entry>
  1367. <entry>
  1368. <key>Unmatched Field Behavior</key>
  1369. <value>
  1370. <name>Unmatched Field Behavior</name>
  1371. </value>
  1372. </entry>
  1373. <entry>
  1374. <key>Unmatched Column Behavior</key>
  1375. <value>
  1376. <name>Unmatched Column Behavior</name>
  1377. </value>
  1378. </entry>
  1379. <entry>
  1380. <key>Update Keys</key>
  1381. <value>
  1382. <name>Update Keys</name>
  1383. </value>
  1384. </entry>
  1385. <entry>
  1386. <key>jts-quoted-identifiers</key>
  1387. <value>
  1388. <name>jts-quoted-identifiers</name>
  1389. </value>
  1390. </entry>
  1391. <entry>
  1392. <key>jts-quoted-table-identifiers</key>
  1393. <value>
  1394. <name>jts-quoted-table-identifiers</name>
  1395. </value>
  1396. </entry>
  1397. </descriptors>
  1398. <executionNode>ALL</executionNode>
  1399. <lossTolerant>false</lossTolerant>
  1400. <penaltyDuration>30 sec</penaltyDuration>
  1401. <properties>
  1402. <entry>
  1403. <key>JDBC Connection Pool</key>
  1404. <value>d3095cea-015a-1000-0000-000000000000</value>
  1405. </entry>
  1406. <entry>
  1407. <key>Statement Type</key>
  1408. <value>INSERT</value>
  1409. </entry>
  1410. <entry>
  1411. <key>Table Name</key>
  1412. <value>${tableName}</value>
  1413. </entry>
  1414. <entry>
  1415. <key>Catalog Name</key>
  1416. </entry>
  1417. <entry>
  1418. <key>Schema Name</key>
  1419. </entry>
  1420. <entry>
  1421. <key>Translate Field Names</key>
  1422. <value>true</value>
  1423. </entry>
  1424. <entry>
  1425. <key>Unmatched Field Behavior</key>
  1426. <value>Ignore Unmatched Fields</value>
  1427. </entry>
  1428. <entry>
  1429. <key>Unmatched Column Behavior</key>
  1430. <value>Ignore Unmatched Columns</value>
  1431. </entry>
  1432. <entry>
  1433. <key>Update Keys</key>
  1434. </entry>
  1435. <entry>
  1436. <key>jts-quoted-identifiers</key>
  1437. <value>false</value>
  1438. </entry>
  1439. <entry>
  1440. <key>jts-quoted-table-identifiers</key>
  1441. <value>false</value>
  1442. </entry>
  1443. </properties>
  1444. <runDurationMillis>0</runDurationMillis>
  1445. <schedulingPeriod>0 sec</schedulingPeriod>
  1446. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1447. <yieldDuration>1 sec</yieldDuration>
  1448. </config>
  1449. <name>Generate INSERT</name>
  1450. <relationships>
  1451. <autoTerminate>false</autoTerminate>
  1452. <name>failure</name>
  1453. </relationships>
  1454. <relationships>
  1455. <autoTerminate>true</autoTerminate>
  1456. <name>original</name>
  1457. </relationships>
  1458. <relationships>
  1459. <autoTerminate>false</autoTerminate>
  1460. <name>sql</name>
  1461. </relationships>
  1462. <style></style>
  1463. <type>org.apache.nifi.processors.standard.ConvertJSONToSQL</type>
  1464. </processors>
  1465. <processors>
  1466. <id>eca06560-015a-1000-0000-000000000000</id>
  1467. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1468. <position>
  1469. <x>413.92256350531557</x>
  1470. <y>1.9993181814584204</y>
  1471. </position>
  1472. <config>
  1473. <bulletinLevel>WARN</bulletinLevel>
  1474. <comments></comments>
  1475. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1476. <descriptors>
  1477. <entry>
  1478. <key>Destination</key>
  1479. <value>
  1480. <name>Destination</name>
  1481. </value>
  1482. </entry>
  1483. <entry>
  1484. <key>Return Type</key>
  1485. <value>
  1486. <name>Return Type</name>
  1487. </value>
  1488. </entry>
  1489. <entry>
  1490. <key>Path Not Found Behavior</key>
  1491. <value>
  1492. <name>Path Not Found Behavior</name>
  1493. </value>
  1494. </entry>
  1495. <entry>
  1496. <key>Null Value Representation</key>
  1497. <value>
  1498. <name>Null Value Representation</name>
  1499. </value>
  1500. </entry>
  1501. <entry>
  1502. <key>tableName</key>
  1503. <value>
  1504. <name>tableName</name>
  1505. </value>
  1506. </entry>
  1507. </descriptors>
  1508. <executionNode>ALL</executionNode>
  1509. <lossTolerant>false</lossTolerant>
  1510. <penaltyDuration>30 sec</penaltyDuration>
  1511. <properties>
  1512. <entry>
  1513. <key>Destination</key>
  1514. <value>flowfile-attribute</value>
  1515. </entry>
  1516. <entry>
  1517. <key>Return Type</key>
  1518. <value>auto-detect</value>
  1519. </entry>
  1520. <entry>
  1521. <key>Path Not Found Behavior</key>
  1522. <value>ignore</value>
  1523. </entry>
  1524. <entry>
  1525. <key>Null Value Representation</key>
  1526. <value>empty string</value>
  1527. </entry>
  1528. <entry>
  1529. <key>tableName</key>
  1530. <value>$.table_name</value>
  1531. </entry>
  1532. </properties>
  1533. <runDurationMillis>0</runDurationMillis>
  1534. <schedulingPeriod>0 sec</schedulingPeriod>
  1535. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1536. <yieldDuration>1 sec</yieldDuration>
  1537. </config>
  1538. <name>Get Table Name</name>
  1539. <relationships>
  1540. <autoTerminate>true</autoTerminate>
  1541. <name>failure</name>
  1542. </relationships>
  1543. <relationships>
  1544. <autoTerminate>false</autoTerminate>
  1545. <name>matched</name>
  1546. </relationships>
  1547. <relationships>
  1548. <autoTerminate>true</autoTerminate>
  1549. <name>unmatched</name>
  1550. </relationships>
  1551. <style></style>
  1552. <type>org.apache.nifi.processors.standard.EvaluateJsonPath</type>
  1553. </processors>
  1554. <processors>
  1555. <id>eca7d36a-015a-1000-0000-000000000000</id>
  1556. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1557. <position>
  1558. <x>564.692962106576</x>
  1559. <y>260.05247386486235</y>
  1560. </position>
  1561. <config>
  1562. <bulletinLevel>WARN</bulletinLevel>
  1563. <comments></comments>
  1564. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1565. <descriptors>
  1566. <entry>
  1567. <key>Destination</key>
  1568. <value>
  1569. <name>Destination</name>
  1570. </value>
  1571. </entry>
  1572. <entry>
  1573. <key>Return Type</key>
  1574. <value>
  1575. <name>Return Type</name>
  1576. </value>
  1577. </entry>
  1578. <entry>
  1579. <key>Path Not Found Behavior</key>
  1580. <value>
  1581. <name>Path Not Found Behavior</name>
  1582. </value>
  1583. </entry>
  1584. <entry>
  1585. <key>Null Value Representation</key>
  1586. <value>
  1587. <name>Null Value Representation</name>
  1588. </value>
  1589. </entry>
  1590. <entry>
  1591. <key>x</key>
  1592. <value>
  1593. <name>x</name>
  1594. </value>
  1595. </entry>
  1596. </descriptors>
  1597. <executionNode>ALL</executionNode>
  1598. <lossTolerant>false</lossTolerant>
  1599. <penaltyDuration>30 sec</penaltyDuration>
  1600. <properties>
  1601. <entry>
  1602. <key>Destination</key>
  1603. <value>flowfile-content</value>
  1604. </entry>
  1605. <entry>
  1606. <key>Return Type</key>
  1607. <value>scalar</value>
  1608. </entry>
  1609. <entry>
  1610. <key>Path Not Found Behavior</key>
  1611. <value>ignore</value>
  1612. </entry>
  1613. <entry>
  1614. <key>Null Value Representation</key>
  1615. <value>empty string</value>
  1616. </entry>
  1617. <entry>
  1618. <key>x</key>
  1619. <value>$.query</value>
  1620. </entry>
  1621. </properties>
  1622. <runDurationMillis>0</runDurationMillis>
  1623. <schedulingPeriod>0 sec</schedulingPeriod>
  1624. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1625. <yieldDuration>1 sec</yieldDuration>
  1626. </config>
  1627. <name>Replace with SQL</name>
  1628. <relationships>
  1629. <autoTerminate>true</autoTerminate>
  1630. <name>failure</name>
  1631. </relationships>
  1632. <relationships>
  1633. <autoTerminate>false</autoTerminate>
  1634. <name>matched</name>
  1635. </relationships>
  1636. <relationships>
  1637. <autoTerminate>true</autoTerminate>
  1638. <name>unmatched</name>
  1639. </relationships>
  1640. <style></style>
  1641. <type>org.apache.nifi.processors.standard.EvaluateJsonPath</type>
  1642. </processors>
  1643. <processors>
  1644. <id>fbbffda6-015a-1000-0000-000000000000</id>
  1645. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1646. <position>
  1647. <x>1554.81991079723</x>
  1648. <y>0.0</y>
  1649. </position>
  1650. <config>
  1651. <bulletinLevel>WARN</bulletinLevel>
  1652. <comments></comments>
  1653. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1654. <descriptors>
  1655. <entry>
  1656. <key>Routing Strategy</key>
  1657. <value>
  1658. <name>Routing Strategy</name>
  1659. </value>
  1660. </entry>
  1661. <entry>
  1662. <key>delete</key>
  1663. <value>
  1664. <name>delete</name>
  1665. </value>
  1666. </entry>
  1667. <entry>
  1668. <key>insert</key>
  1669. <value>
  1670. <name>insert</name>
  1671. </value>
  1672. </entry>
  1673. <entry>
  1674. <key>update</key>
  1675. <value>
  1676. <name>update</name>
  1677. </value>
  1678. </entry>
  1679. </descriptors>
  1680. <executionNode>ALL</executionNode>
  1681. <lossTolerant>false</lossTolerant>
  1682. <penaltyDuration>30 sec</penaltyDuration>
  1683. <properties>
  1684. <entry>
  1685. <key>Routing Strategy</key>
  1686. <value>Route to Property name</value>
  1687. </entry>
  1688. <entry>
  1689. <key>delete</key>
  1690. <value>${cdc.event.type:equals('delete')}</value>
  1691. </entry>
  1692. <entry>
  1693. <key>insert</key>
  1694. <value>${cdc.event.type:equals('write')}</value>
  1695. </entry>
  1696. <entry>
  1697. <key>update</key>
  1698. <value>${cdc.event.type:equals('update')}</value>
  1699. </entry>
  1700. </properties>
  1701. <runDurationMillis>0</runDurationMillis>
  1702. <schedulingPeriod>0 sec</schedulingPeriod>
  1703. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1704. <yieldDuration>1 sec</yieldDuration>
  1705. </config>
  1706. <name>Route To SQL Generator</name>
  1707. <relationships>
  1708. <autoTerminate>false</autoTerminate>
  1709. <name>delete</name>
  1710. </relationships>
  1711. <relationships>
  1712. <autoTerminate>false</autoTerminate>
  1713. <name>insert</name>
  1714. </relationships>
  1715. <relationships>
  1716. <autoTerminate>true</autoTerminate>
  1717. <name>unmatched</name>
  1718. </relationships>
  1719. <relationships>
  1720. <autoTerminate>false</autoTerminate>
  1721. <name>update</name>
  1722. </relationships>
  1723. <style></style>
  1724. <type>org.apache.nifi.processors.standard.RouteOnAttribute</type>
  1725. </processors>
  1726. <processors>
  1727. <id>fbc0555b-015a-1000-0000-000000000000</id>
  1728. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1729. <position>
  1730. <x>1412.3481023819595</x>
  1731. <y>248.2600307894959</y>
  1732. </position>
  1733. <config>
  1734. <bulletinLevel>WARN</bulletinLevel>
  1735. <comments></comments>
  1736. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1737. <descriptors>
  1738. <entry>
  1739. <key>JDBC Connection Pool</key>
  1740. <value>
  1741. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  1742. <name>JDBC Connection Pool</name>
  1743. </value>
  1744. </entry>
  1745. <entry>
  1746. <key>Statement Type</key>
  1747. <value>
  1748. <name>Statement Type</name>
  1749. </value>
  1750. </entry>
  1751. <entry>
  1752. <key>Table Name</key>
  1753. <value>
  1754. <name>Table Name</name>
  1755. </value>
  1756. </entry>
  1757. <entry>
  1758. <key>Catalog Name</key>
  1759. <value>
  1760. <name>Catalog Name</name>
  1761. </value>
  1762. </entry>
  1763. <entry>
  1764. <key>Schema Name</key>
  1765. <value>
  1766. <name>Schema Name</name>
  1767. </value>
  1768. </entry>
  1769. <entry>
  1770. <key>Translate Field Names</key>
  1771. <value>
  1772. <name>Translate Field Names</name>
  1773. </value>
  1774. </entry>
  1775. <entry>
  1776. <key>Unmatched Field Behavior</key>
  1777. <value>
  1778. <name>Unmatched Field Behavior</name>
  1779. </value>
  1780. </entry>
  1781. <entry>
  1782. <key>Unmatched Column Behavior</key>
  1783. <value>
  1784. <name>Unmatched Column Behavior</name>
  1785. </value>
  1786. </entry>
  1787. <entry>
  1788. <key>Update Keys</key>
  1789. <value>
  1790. <name>Update Keys</name>
  1791. </value>
  1792. </entry>
  1793. <entry>
  1794. <key>jts-quoted-identifiers</key>
  1795. <value>
  1796. <name>jts-quoted-identifiers</name>
  1797. </value>
  1798. </entry>
  1799. <entry>
  1800. <key>jts-quoted-table-identifiers</key>
  1801. <value>
  1802. <name>jts-quoted-table-identifiers</name>
  1803. </value>
  1804. </entry>
  1805. </descriptors>
  1806. <executionNode>ALL</executionNode>
  1807. <lossTolerant>false</lossTolerant>
  1808. <penaltyDuration>30 sec</penaltyDuration>
  1809. <properties>
  1810. <entry>
  1811. <key>JDBC Connection Pool</key>
  1812. <value>d3095cea-015a-1000-0000-000000000000</value>
  1813. </entry>
  1814. <entry>
  1815. <key>Statement Type</key>
  1816. <value>UPDATE</value>
  1817. </entry>
  1818. <entry>
  1819. <key>Table Name</key>
  1820. <value>${tableName}</value>
  1821. </entry>
  1822. <entry>
  1823. <key>Catalog Name</key>
  1824. </entry>
  1825. <entry>
  1826. <key>Schema Name</key>
  1827. </entry>
  1828. <entry>
  1829. <key>Translate Field Names</key>
  1830. <value>true</value>
  1831. </entry>
  1832. <entry>
  1833. <key>Unmatched Field Behavior</key>
  1834. <value>Ignore Unmatched Fields</value>
  1835. </entry>
  1836. <entry>
  1837. <key>Unmatched Column Behavior</key>
  1838. <value>Ignore Unmatched Columns</value>
  1839. </entry>
  1840. <entry>
  1841. <key>Update Keys</key>
  1842. </entry>
  1843. <entry>
  1844. <key>jts-quoted-identifiers</key>
  1845. <value>false</value>
  1846. </entry>
  1847. <entry>
  1848. <key>jts-quoted-table-identifiers</key>
  1849. <value>false</value>
  1850. </entry>
  1851. </properties>
  1852. <runDurationMillis>0</runDurationMillis>
  1853. <schedulingPeriod>0 sec</schedulingPeriod>
  1854. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1855. <yieldDuration>1 sec</yieldDuration>
  1856. </config>
  1857. <name>Generate UPDATE</name>
  1858. <relationships>
  1859. <autoTerminate>false</autoTerminate>
  1860. <name>failure</name>
  1861. </relationships>
  1862. <relationships>
  1863. <autoTerminate>true</autoTerminate>
  1864. <name>original</name>
  1865. </relationships>
  1866. <relationships>
  1867. <autoTerminate>false</autoTerminate>
  1868. <name>sql</name>
  1869. </relationships>
  1870. <style></style>
  1871. <type>org.apache.nifi.processors.standard.ConvertJSONToSQL</type>
  1872. </processors>
  1873. <processors>
  1874. <id>fbc0c003-015a-1000-0000-000000000000</id>
  1875. <parentGroupId>faf788c5-015a-1000-0000-000000000000</parentGroupId>
  1876. <position>
  1877. <x>1824.0209539444595</x>
  1878. <y>249.896780057074</y>
  1879. </position>
  1880. <config>
  1881. <bulletinLevel>WARN</bulletinLevel>
  1882. <comments></comments>
  1883. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1884. <descriptors>
  1885. <entry>
  1886. <key>JDBC Connection Pool</key>
  1887. <value>
  1888. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  1889. <name>JDBC Connection Pool</name>
  1890. </value>
  1891. </entry>
  1892. <entry>
  1893. <key>Statement Type</key>
  1894. <value>
  1895. <name>Statement Type</name>
  1896. </value>
  1897. </entry>
  1898. <entry>
  1899. <key>Table Name</key>
  1900. <value>
  1901. <name>Table Name</name>
  1902. </value>
  1903. </entry>
  1904. <entry>
  1905. <key>Catalog Name</key>
  1906. <value>
  1907. <name>Catalog Name</name>
  1908. </value>
  1909. </entry>
  1910. <entry>
  1911. <key>Schema Name</key>
  1912. <value>
  1913. <name>Schema Name</name>
  1914. </value>
  1915. </entry>
  1916. <entry>
  1917. <key>Translate Field Names</key>
  1918. <value>
  1919. <name>Translate Field Names</name>
  1920. </value>
  1921. </entry>
  1922. <entry>
  1923. <key>Unmatched Field Behavior</key>
  1924. <value>
  1925. <name>Unmatched Field Behavior</name>
  1926. </value>
  1927. </entry>
  1928. <entry>
  1929. <key>Unmatched Column Behavior</key>
  1930. <value>
  1931. <name>Unmatched Column Behavior</name>
  1932. </value>
  1933. </entry>
  1934. <entry>
  1935. <key>Update Keys</key>
  1936. <value>
  1937. <name>Update Keys</name>
  1938. </value>
  1939. </entry>
  1940. <entry>
  1941. <key>jts-quoted-identifiers</key>
  1942. <value>
  1943. <name>jts-quoted-identifiers</name>
  1944. </value>
  1945. </entry>
  1946. <entry>
  1947. <key>jts-quoted-table-identifiers</key>
  1948. <value>
  1949. <name>jts-quoted-table-identifiers</name>
  1950. </value>
  1951. </entry>
  1952. </descriptors>
  1953. <executionNode>ALL</executionNode>
  1954. <lossTolerant>false</lossTolerant>
  1955. <penaltyDuration>30 sec</penaltyDuration>
  1956. <properties>
  1957. <entry>
  1958. <key>JDBC Connection Pool</key>
  1959. <value>d3095cea-015a-1000-0000-000000000000</value>
  1960. </entry>
  1961. <entry>
  1962. <key>Statement Type</key>
  1963. <value>DELETE</value>
  1964. </entry>
  1965. <entry>
  1966. <key>Table Name</key>
  1967. <value>${tableName}</value>
  1968. </entry>
  1969. <entry>
  1970. <key>Catalog Name</key>
  1971. </entry>
  1972. <entry>
  1973. <key>Schema Name</key>
  1974. </entry>
  1975. <entry>
  1976. <key>Translate Field Names</key>
  1977. <value>true</value>
  1978. </entry>
  1979. <entry>
  1980. <key>Unmatched Field Behavior</key>
  1981. <value>Ignore Unmatched Fields</value>
  1982. </entry>
  1983. <entry>
  1984. <key>Unmatched Column Behavior</key>
  1985. <value>Ignore Unmatched Columns</value>
  1986. </entry>
  1987. <entry>
  1988. <key>Update Keys</key>
  1989. </entry>
  1990. <entry>
  1991. <key>jts-quoted-identifiers</key>
  1992. <value>false</value>
  1993. </entry>
  1994. <entry>
  1995. <key>jts-quoted-table-identifiers</key>
  1996. <value>false</value>
  1997. </entry>
  1998. </properties>
  1999. <runDurationMillis>0</runDurationMillis>
  2000. <schedulingPeriod>0 sec</schedulingPeriod>
  2001. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  2002. <yieldDuration>1 sec</yieldDuration>
  2003. </config>
  2004. <name>Generate DELETE</name>
  2005. <relationships>
  2006. <autoTerminate>false</autoTerminate>
  2007. <name>failure</name>
  2008. </relationships>
  2009. <relationships>
  2010. <autoTerminate>true</autoTerminate>
  2011. <name>original</name>
  2012. </relationships>
  2013. <relationships>
  2014. <autoTerminate>false</autoTerminate>
  2015. <name>sql</name>
  2016. </relationships>
  2017. <style></style>
  2018. <type>org.apache.nifi.processors.standard.ConvertJSONToSQL</type>
  2019. </processors>
  2020. </snippet>
  2021. <timestamp>03/23/2017 18:01:41 EDT</timestamp>
  2022. </template>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!