API tools faq
paste
Guest User

Untitled

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