Advertisement
Guest User

Untitled

a guest
Apr 18th, 2017
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 46.52 KB | None | 0 0
  1. <?xml version="1.0" ?>
  2. <template encoding-version="1.1">
  3. <description></description>
  4. <groupId>7ebaf566-015b-1000-b416-922a420ea741</groupId>
  5. <name>ConvertRecord_examples</name>
  6. <snippet>
  7. <connections>
  8. <id>81dd9a51-07c4-39f0-0000-000000000000</id>
  9. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  10. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  11. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  12. <destination>
  13. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  14. <id>e7432dc4-d030-325c-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>868f7eec-2b0e-352b-0000-000000000000</groupId>
  23. <id>20004fbd-20c9-3a44-0000-000000000000</id>
  24. <type>PROCESSOR</type>
  25. </source>
  26. <zIndex>0</zIndex>
  27. </connections>
  28. <connections>
  29. <id>8eada676-c98e-390a-0000-000000000000</id>
  30. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  31. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  32. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  33. <destination>
  34. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  35. <id>ca0aff29-42b6-3979-0000-000000000000</id>
  36. <type>PROCESSOR</type>
  37. </destination>
  38. <flowFileExpiration>0 sec</flowFileExpiration>
  39. <labelIndex>1</labelIndex>
  40. <name></name>
  41. <selectedRelationships>success</selectedRelationships>
  42. <source>
  43. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  44. <id>e372ac4b-0e15-3e07-0000-000000000000</id>
  45. <type>PROCESSOR</type>
  46. </source>
  47. <zIndex>0</zIndex>
  48. </connections>
  49. <connections>
  50. <id>ae5b7188-8cbf-378c-0000-000000000000</id>
  51. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  52. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  53. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  54. <destination>
  55. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  56. <id>8cba5630-5c67-3018-0000-000000000000</id>
  57. <type>PROCESSOR</type>
  58. </destination>
  59. <flowFileExpiration>0 sec</flowFileExpiration>
  60. <labelIndex>1</labelIndex>
  61. <name></name>
  62. <selectedRelationships>success</selectedRelationships>
  63. <source>
  64. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  65. <id>7ff23431-7ac9-348b-0000-000000000000</id>
  66. <type>PROCESSOR</type>
  67. </source>
  68. <zIndex>0</zIndex>
  69. </connections>
  70. <connections>
  71. <id>f8914865-2f7a-37e6-0000-000000000000</id>
  72. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  73. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  74. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  75. <destination>
  76. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  77. <id>9528b6c8-0704-3d38-0000-000000000000</id>
  78. <type>PROCESSOR</type>
  79. </destination>
  80. <flowFileExpiration>0 sec</flowFileExpiration>
  81. <labelIndex>1</labelIndex>
  82. <name></name>
  83. <selectedRelationships>success</selectedRelationships>
  84. <source>
  85. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  86. <id>50380fd4-2678-3551-0000-000000000000</id>
  87. <type>PROCESSOR</type>
  88. </source>
  89. <zIndex>0</zIndex>
  90. </connections>
  91. <connections>
  92. <id>fe624d5a-e6ec-3f60-0000-000000000000</id>
  93. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  94. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  95. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  96. <destination>
  97. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  98. <id>e372ac4b-0e15-3e07-0000-000000000000</id>
  99. <type>PROCESSOR</type>
  100. </destination>
  101. <flowFileExpiration>0 sec</flowFileExpiration>
  102. <labelIndex>1</labelIndex>
  103. <name></name>
  104. <selectedRelationships>success</selectedRelationships>
  105. <source>
  106. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  107. <id>8cba5630-5c67-3018-0000-000000000000</id>
  108. <type>PROCESSOR</type>
  109. </source>
  110. <zIndex>0</zIndex>
  111. </connections>
  112. <connections>
  113. <id>ffe62f66-6f3d-3142-0000-000000000000</id>
  114. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  115. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  116. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  117. <destination>
  118. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  119. <id>34ab082f-e5df-3717-0000-000000000000</id>
  120. <type>PROCESSOR</type>
  121. </destination>
  122. <flowFileExpiration>0 sec</flowFileExpiration>
  123. <labelIndex>1</labelIndex>
  124. <name></name>
  125. <selectedRelationships>success</selectedRelationships>
  126. <source>
  127. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  128. <id>e7432dc4-d030-325c-0000-000000000000</id>
  129. <type>PROCESSOR</type>
  130. </source>
  131. <zIndex>0</zIndex>
  132. </connections>
  133. <connections>
  134. <id>0639f3c9-d3f2-3ebb-0000-000000000000</id>
  135. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  136. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  137. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  138. <destination>
  139. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  140. <id>9528b6c8-0704-3d38-0000-000000000000</id>
  141. <type>PROCESSOR</type>
  142. </destination>
  143. <flowFileExpiration>0 sec</flowFileExpiration>
  144. <labelIndex>1</labelIndex>
  145. <name></name>
  146. <selectedRelationships>success</selectedRelationships>
  147. <source>
  148. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  149. <id>34ab082f-e5df-3717-0000-000000000000</id>
  150. <type>PROCESSOR</type>
  151. </source>
  152. <zIndex>0</zIndex>
  153. </connections>
  154. <connections>
  155. <id>0f0e58bb-8a51-3daa-0000-000000000000</id>
  156. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  157. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  158. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  159. <destination>
  160. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  161. <id>9528b6c8-0704-3d38-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>868f7eec-2b0e-352b-0000-000000000000</groupId>
  170. <id>ca0aff29-42b6-3979-0000-000000000000</id>
  171. <type>PROCESSOR</type>
  172. </source>
  173. <zIndex>0</zIndex>
  174. </connections>
  175. <connections>
  176. <id>398721a6-fd5b-3c48-0000-000000000000</id>
  177. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  178. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  179. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  180. <destination>
  181. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  182. <id>beab5fcd-61dd-300f-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>868f7eec-2b0e-352b-0000-000000000000</groupId>
  191. <id>e7432dc4-d030-325c-0000-000000000000</id>
  192. <type>PROCESSOR</type>
  193. </source>
  194. <zIndex>0</zIndex>
  195. </connections>
  196. <connections>
  197. <id>7276ec25-d5ba-339d-0000-000000000000</id>
  198. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  199. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  200. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  201. <destination>
  202. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  203. <id>50380fd4-2678-3551-0000-000000000000</id>
  204. <type>PROCESSOR</type>
  205. </destination>
  206. <flowFileExpiration>0 sec</flowFileExpiration>
  207. <labelIndex>1</labelIndex>
  208. <name></name>
  209. <selectedRelationships>success</selectedRelationships>
  210. <source>
  211. <groupId>868f7eec-2b0e-352b-0000-000000000000</groupId>
  212. <id>beab5fcd-61dd-300f-0000-000000000000</id>
  213. <type>PROCESSOR</type>
  214. </source>
  215. <zIndex>0</zIndex>
  216. </connections>
  217. <controllerServices>
  218. <id>adc75919-ace6-381a-0000-000000000000</id>
  219. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  220. <bundle>
  221. <artifact>nifi-record-serialization-services-nar</artifact>
  222. <group>org.apache.nifi</group>
  223. <version>1.2.0-SNAPSHOT</version>
  224. </bundle>
  225. <comments></comments>
  226. <descriptors>
  227. <entry>
  228. <key>Date Format</key>
  229. <value>
  230. <name>Date Format</name>
  231. </value>
  232. </entry>
  233. <entry>
  234. <key>Time Format</key>
  235. <value>
  236. <name>Time Format</name>
  237. </value>
  238. </entry>
  239. <entry>
  240. <key>Timestamp Format</key>
  241. <value>
  242. <name>Timestamp Format</name>
  243. </value>
  244. </entry>
  245. <entry>
  246. <key>CSV Format</key>
  247. <value>
  248. <name>CSV Format</name>
  249. </value>
  250. </entry>
  251. <entry>
  252. <key>Value Separator</key>
  253. <value>
  254. <name>Value Separator</name>
  255. </value>
  256. </entry>
  257. <entry>
  258. <key>Quote Character</key>
  259. <value>
  260. <name>Quote Character</name>
  261. </value>
  262. </entry>
  263. <entry>
  264. <key>Escape Character</key>
  265. <value>
  266. <name>Escape Character</name>
  267. </value>
  268. </entry>
  269. <entry>
  270. <key>Comment Marker</key>
  271. <value>
  272. <name>Comment Marker</name>
  273. </value>
  274. </entry>
  275. <entry>
  276. <key>Null String</key>
  277. <value>
  278. <name>Null String</name>
  279. </value>
  280. </entry>
  281. <entry>
  282. <key>Trim Fields</key>
  283. <value>
  284. <name>Trim Fields</name>
  285. </value>
  286. </entry>
  287. <entry>
  288. <key>Quote Mode</key>
  289. <value>
  290. <name>Quote Mode</name>
  291. </value>
  292. </entry>
  293. <entry>
  294. <key>Record Separator</key>
  295. <value>
  296. <name>Record Separator</name>
  297. </value>
  298. </entry>
  299. <entry>
  300. <key>Include Trailing Delimiter</key>
  301. <value>
  302. <name>Include Trailing Delimiter</name>
  303. </value>
  304. </entry>
  305. </descriptors>
  306. <name>CSVRecordSetWriter</name>
  307. <persistsState>false</persistsState>
  308. <properties>
  309. <entry>
  310. <key>Date Format</key>
  311. </entry>
  312. <entry>
  313. <key>Time Format</key>
  314. </entry>
  315. <entry>
  316. <key>Timestamp Format</key>
  317. </entry>
  318. <entry>
  319. <key>CSV Format</key>
  320. </entry>
  321. <entry>
  322. <key>Value Separator</key>
  323. </entry>
  324. <entry>
  325. <key>Quote Character</key>
  326. </entry>
  327. <entry>
  328. <key>Escape Character</key>
  329. </entry>
  330. <entry>
  331. <key>Comment Marker</key>
  332. </entry>
  333. <entry>
  334. <key>Null String</key>
  335. </entry>
  336. <entry>
  337. <key>Trim Fields</key>
  338. </entry>
  339. <entry>
  340. <key>Quote Mode</key>
  341. </entry>
  342. <entry>
  343. <key>Record Separator</key>
  344. </entry>
  345. <entry>
  346. <key>Include Trailing Delimiter</key>
  347. </entry>
  348. </properties>
  349. <state>ENABLED</state>
  350. <type>org.apache.nifi.csv.CSVRecordSetWriter</type>
  351. </controllerServices>
  352. <controllerServices>
  353. <id>d33e98e7-978b-3662-0000-000000000000</id>
  354. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  355. <bundle>
  356. <artifact>nifi-dbcp-service-nar</artifact>
  357. <group>org.apache.nifi</group>
  358. <version>1.2.0-SNAPSHOT</version>
  359. </bundle>
  360. <comments></comments>
  361. <descriptors>
  362. <entry>
  363. <key>Database Connection URL</key>
  364. <value>
  365. <name>Database Connection URL</name>
  366. </value>
  367. </entry>
  368. <entry>
  369. <key>Database Driver Class Name</key>
  370. <value>
  371. <name>Database Driver Class Name</name>
  372. </value>
  373. </entry>
  374. <entry>
  375. <key>database-driver-locations</key>
  376. <value>
  377. <name>database-driver-locations</name>
  378. </value>
  379. </entry>
  380. <entry>
  381. <key>Database User</key>
  382. <value>
  383. <name>Database User</name>
  384. </value>
  385. </entry>
  386. <entry>
  387. <key>Password</key>
  388. <value>
  389. <name>Password</name>
  390. </value>
  391. </entry>
  392. <entry>
  393. <key>Max Wait Time</key>
  394. <value>
  395. <name>Max Wait Time</name>
  396. </value>
  397. </entry>
  398. <entry>
  399. <key>Max Total Connections</key>
  400. <value>
  401. <name>Max Total Connections</name>
  402. </value>
  403. </entry>
  404. <entry>
  405. <key>Validation-query</key>
  406. <value>
  407. <name>Validation-query</name>
  408. </value>
  409. </entry>
  410. </descriptors>
  411. <name>MySQLConnectionPool</name>
  412. <persistsState>false</persistsState>
  413. <properties>
  414. <entry>
  415. <key>Database Connection URL</key>
  416. <value>jdbc:mysql://192.168.99.100:32768/test_schema</value>
  417. </entry>
  418. <entry>
  419. <key>Database Driver Class Name</key>
  420. <value>com.mysql.jdbc.Driver</value>
  421. </entry>
  422. <entry>
  423. <key>database-driver-locations</key>
  424. <value>file:///Users/mburgess/jdbc_drivers/mysql-connector-java-5.1.38-bin.jar</value>
  425. </entry>
  426. <entry>
  427. <key>Database User</key>
  428. <value>root</value>
  429. </entry>
  430. <entry>
  431. <key>Password</key>
  432. </entry>
  433. <entry>
  434. <key>Max Wait Time</key>
  435. <value>500 millis</value>
  436. </entry>
  437. <entry>
  438. <key>Max Total Connections</key>
  439. <value>8</value>
  440. </entry>
  441. <entry>
  442. <key>Validation-query</key>
  443. </entry>
  444. </properties>
  445. <state>ENABLED</state>
  446. <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
  447. </controllerServices>
  448. <controllerServices>
  449. <id>d37bd3a4-50d6-369a-0000-000000000000</id>
  450. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  451. <bundle>
  452. <artifact>nifi-record-serialization-services-nar</artifact>
  453. <group>org.apache.nifi</group>
  454. <version>1.2.0-SNAPSHOT</version>
  455. </bundle>
  456. <comments></comments>
  457. <descriptors>
  458. <entry>
  459. <key>Date Format</key>
  460. <value>
  461. <name>Date Format</name>
  462. </value>
  463. </entry>
  464. <entry>
  465. <key>Time Format</key>
  466. <value>
  467. <name>Time Format</name>
  468. </value>
  469. </entry>
  470. <entry>
  471. <key>Timestamp Format</key>
  472. <value>
  473. <name>Timestamp Format</name>
  474. </value>
  475. </entry>
  476. <entry>
  477. <key>Pretty Print JSON</key>
  478. <value>
  479. <name>Pretty Print JSON</name>
  480. </value>
  481. </entry>
  482. </descriptors>
  483. <name>JsonRecordSetWriter</name>
  484. <persistsState>false</persistsState>
  485. <properties>
  486. <entry>
  487. <key>Date Format</key>
  488. </entry>
  489. <entry>
  490. <key>Time Format</key>
  491. </entry>
  492. <entry>
  493. <key>Timestamp Format</key>
  494. </entry>
  495. <entry>
  496. <key>Pretty Print JSON</key>
  497. <value>true</value>
  498. </entry>
  499. </properties>
  500. <state>ENABLED</state>
  501. <type>org.apache.nifi.json.JsonRecordSetWriter</type>
  502. </controllerServices>
  503. <controllerServices>
  504. <id>d56dac0d-dfa2-3e17-0000-000000000000</id>
  505. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  506. <bundle>
  507. <artifact>nifi-record-serialization-services-nar</artifact>
  508. <group>org.apache.nifi</group>
  509. <version>1.2.0-SNAPSHOT</version>
  510. </bundle>
  511. <comments></comments>
  512. <descriptors>
  513. <entry>
  514. <key>Avro Schema</key>
  515. <value>
  516. <name>Avro Schema</name>
  517. </value>
  518. </entry>
  519. </descriptors>
  520. <name>Avro Name Record Writer</name>
  521. <persistsState>false</persistsState>
  522. <properties>
  523. <entry>
  524. <key>Avro Schema</key>
  525. <value>{
  526. "type": "record",
  527. "name": "name",
  528. "fields" : [
  529. {"name": "id", "type": "long"},
  530. {"name": "name", "type": ["null", "string"]}
  531. ]
  532. }</value>
  533. </entry>
  534. </properties>
  535. <state>ENABLED</state>
  536. <type>org.apache.nifi.avro.AvroRecordSetWriter</type>
  537. </controllerServices>
  538. <controllerServices>
  539. <id>f0788303-8156-3d11-0000-000000000000</id>
  540. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  541. <bundle>
  542. <artifact>nifi-record-serialization-services-nar</artifact>
  543. <group>org.apache.nifi</group>
  544. <version>1.2.0-SNAPSHOT</version>
  545. </bundle>
  546. <descriptors></descriptors>
  547. <name>AvroReader</name>
  548. <persistsState>false</persistsState>
  549. <properties></properties>
  550. <state>ENABLED</state>
  551. <type>org.apache.nifi.avro.AvroReader</type>
  552. </controllerServices>
  553. <controllerServices>
  554. <id>0e095f2c-1d29-3816-0000-000000000000</id>
  555. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  556. <bundle>
  557. <artifact>nifi-record-serialization-services-nar</artifact>
  558. <group>org.apache.nifi</group>
  559. <version>1.2.0-SNAPSHOT</version>
  560. </bundle>
  561. <comments></comments>
  562. <descriptors>
  563. <entry>
  564. <key>Schema Registry</key>
  565. <value>
  566. <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
  567. <name>Schema Registry</name>
  568. </value>
  569. </entry>
  570. <entry>
  571. <key>Schema Name</key>
  572. <value>
  573. <name>Schema Name</name>
  574. </value>
  575. </entry>
  576. <entry>
  577. <key>Date Format</key>
  578. <value>
  579. <name>Date Format</name>
  580. </value>
  581. </entry>
  582. <entry>
  583. <key>Time Format</key>
  584. <value>
  585. <name>Time Format</name>
  586. </value>
  587. </entry>
  588. <entry>
  589. <key>Timestamp Format</key>
  590. <value>
  591. <name>Timestamp Format</name>
  592. </value>
  593. </entry>
  594. </descriptors>
  595. <name>JsonTreeReader</name>
  596. <persistsState>false</persistsState>
  597. <properties>
  598. <entry>
  599. <key>Schema Registry</key>
  600. <value>77999fe0-2764-36ff-0000-000000000000</value>
  601. </entry>
  602. <entry>
  603. <key>Schema Name</key>
  604. <value>${schema.name}</value>
  605. </entry>
  606. <entry>
  607. <key>Date Format</key>
  608. </entry>
  609. <entry>
  610. <key>Time Format</key>
  611. </entry>
  612. <entry>
  613. <key>Timestamp Format</key>
  614. </entry>
  615. </properties>
  616. <state>ENABLED</state>
  617. <type>org.apache.nifi.json.JsonTreeReader</type>
  618. </controllerServices>
  619. <controllerServices>
  620. <id>77999fe0-2764-36ff-0000-000000000000</id>
  621. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  622. <bundle>
  623. <artifact>nifi-registry-nar</artifact>
  624. <group>org.apache.nifi</group>
  625. <version>1.2.0-SNAPSHOT</version>
  626. </bundle>
  627. <comments></comments>
  628. <descriptors>
  629. <entry>
  630. <key>name</key>
  631. <value>
  632. <name>name</name>
  633. </value>
  634. </entry>
  635. <entry>
  636. <key>user</key>
  637. <value>
  638. <name>user</name>
  639. </value>
  640. </entry>
  641. </descriptors>
  642. <name>AvroSchemaRegistry</name>
  643. <persistsState>false</persistsState>
  644. <properties>
  645. <entry>
  646. <key>name</key>
  647. <value>{
  648. "type": "record",
  649. "name": "name",
  650. "fields" : [
  651. {"name": "id", "type": "long"},
  652. {"name": "name", "type": ["null", "string"]}
  653. ]
  654. }</value>
  655. </entry>
  656. <entry>
  657. <key>user</key>
  658. <value>{
  659. "type": "record",
  660. "name": "UserRecord",
  661. "fields" : [
  662. {"name": "id", "type": "long"},
  663. {"name": "title", "type": ["null", "string"]},
  664. {"name": "first", "type": ["null", "string"]},
  665. {"name": "last", "type": ["null", "string"]},
  666. {"name": "street", "type": ["null", "string"]},
  667. {"name": "city", "type": ["null", "string"]},
  668. {"name": "state", "type": ["null", "string"]},
  669. {"name": "zip", "type": ["null", "string"]},
  670. {"name": "gender", "type": ["null", "string"]},
  671. {"name": "email", "type": ["null", "string"]},
  672. {"name": "username", "type": ["null", "string"]},
  673. {"name": "password", "type": ["null", "string"]},
  674. {"name": "phone", "type": ["null", "string"]},
  675. {"name": "cell", "type": ["null", "string"]},
  676. {"name": "ssn", "type": ["null", "string"]},
  677. {"name": "date_of_birth", "type": ["null", "string"]},
  678. {"name": "reg_date", "type": ["null", "string"]},
  679. {"name": "large", "type": ["null", "string"]},
  680. {"name": "medium", "type": ["null", "string"]},
  681. {"name": "thumbnail", "type": ["null", "string"]},
  682. {"name": "version", "type": ["null", "string"]},
  683. {"name": "nationality", "type": ["null", "string"]}
  684. ]
  685. }</value>
  686. </entry>
  687. </properties>
  688. <state>ENABLED</state>
  689. <type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type>
  690. </controllerServices>
  691. <processors>
  692. <id>8cba5630-5c67-3018-0000-000000000000</id>
  693. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  694. <position>
  695. <x>1.9316851631332383</x>
  696. <y>238.6391039237294</y>
  697. </position>
  698. <bundle>
  699. <artifact>nifi-update-attribute-nar</artifact>
  700. <group>org.apache.nifi</group>
  701. <version>1.2.0-SNAPSHOT</version>
  702. </bundle>
  703. <config>
  704. <bulletinLevel>WARN</bulletinLevel>
  705. <comments></comments>
  706. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  707. <descriptors>
  708. <entry>
  709. <key>Delete Attributes Expression</key>
  710. <value>
  711. <name>Delete Attributes Expression</name>
  712. </value>
  713. </entry>
  714. <entry>
  715. <key>Store State</key>
  716. <value>
  717. <name>Store State</name>
  718. </value>
  719. </entry>
  720. <entry>
  721. <key>Stateful Variables Initial Value</key>
  722. <value>
  723. <name>Stateful Variables Initial Value</name>
  724. </value>
  725. </entry>
  726. <entry>
  727. <key>schema.name</key>
  728. <value>
  729. <name>schema.name</name>
  730. </value>
  731. </entry>
  732. </descriptors>
  733. <executionNode>ALL</executionNode>
  734. <lossTolerant>false</lossTolerant>
  735. <penaltyDuration>30 sec</penaltyDuration>
  736. <properties>
  737. <entry>
  738. <key>Delete Attributes Expression</key>
  739. </entry>
  740. <entry>
  741. <key>Store State</key>
  742. <value>Do not store state</value>
  743. </entry>
  744. <entry>
  745. <key>Stateful Variables Initial Value</key>
  746. </entry>
  747. <entry>
  748. <key>schema.name</key>
  749. <value>name</value>
  750. </entry>
  751. </properties>
  752. <runDurationMillis>0</runDurationMillis>
  753. <schedulingPeriod>0 sec</schedulingPeriod>
  754. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  755. <yieldDuration>1 sec</yieldDuration>
  756. </config>
  757. <name>UpdateAttribute</name>
  758. <relationships>
  759. <autoTerminate>false</autoTerminate>
  760. <name>success</name>
  761. </relationships>
  762. <style></style>
  763. <type>org.apache.nifi.processors.attributes.UpdateAttribute</type>
  764. </processors>
  765. <processors>
  766. <id>9528b6c8-0704-3d38-0000-000000000000</id>
  767. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  768. <position>
  769. <x>583.4444542358434</x>
  770. <y>968.3874315607559</y>
  771. </position>
  772. <bundle>
  773. <artifact>nifi-standard-nar</artifact>
  774. <group>org.apache.nifi</group>
  775. <version>1.2.0-SNAPSHOT</version>
  776. </bundle>
  777. <config>
  778. <bulletinLevel>WARN</bulletinLevel>
  779. <comments></comments>
  780. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  781. <descriptors>
  782. <entry>
  783. <key>Log Level</key>
  784. <value>
  785. <name>Log Level</name>
  786. </value>
  787. </entry>
  788. <entry>
  789. <key>Log Payload</key>
  790. <value>
  791. <name>Log Payload</name>
  792. </value>
  793. </entry>
  794. <entry>
  795. <key>Attributes to Log</key>
  796. <value>
  797. <name>Attributes to Log</name>
  798. </value>
  799. </entry>
  800. <entry>
  801. <key>Attributes to Ignore</key>
  802. <value>
  803. <name>Attributes to Ignore</name>
  804. </value>
  805. </entry>
  806. <entry>
  807. <key>Log prefix</key>
  808. <value>
  809. <name>Log prefix</name>
  810. </value>
  811. </entry>
  812. </descriptors>
  813. <executionNode>ALL</executionNode>
  814. <lossTolerant>false</lossTolerant>
  815. <penaltyDuration>30 sec</penaltyDuration>
  816. <properties>
  817. <entry>
  818. <key>Log Level</key>
  819. <value>info</value>
  820. </entry>
  821. <entry>
  822. <key>Log Payload</key>
  823. <value>false</value>
  824. </entry>
  825. <entry>
  826. <key>Attributes to Log</key>
  827. </entry>
  828. <entry>
  829. <key>Attributes to Ignore</key>
  830. </entry>
  831. <entry>
  832. <key>Log prefix</key>
  833. </entry>
  834. </properties>
  835. <runDurationMillis>0</runDurationMillis>
  836. <schedulingPeriod>0 sec</schedulingPeriod>
  837. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  838. <yieldDuration>1 sec</yieldDuration>
  839. </config>
  840. <name>LogAttribute</name>
  841. <relationships>
  842. <autoTerminate>false</autoTerminate>
  843. <name>success</name>
  844. </relationships>
  845. <style></style>
  846. <type>org.apache.nifi.processors.standard.LogAttribute</type>
  847. </processors>
  848. <processors>
  849. <id>beab5fcd-61dd-300f-0000-000000000000</id>
  850. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  851. <position>
  852. <x>1188.6895320845647</x>
  853. <y>431.8511511120013</y>
  854. </position>
  855. <bundle>
  856. <artifact>nifi-avro-nar</artifact>
  857. <group>org.apache.nifi</group>
  858. <version>1.2.0-SNAPSHOT</version>
  859. </bundle>
  860. <config>
  861. <bulletinLevel>WARN</bulletinLevel>
  862. <comments></comments>
  863. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  864. <descriptors>
  865. <entry>
  866. <key>JSON container options</key>
  867. <value>
  868. <name>JSON container options</name>
  869. </value>
  870. </entry>
  871. <entry>
  872. <key>Wrap Single Record</key>
  873. <value>
  874. <name>Wrap Single Record</name>
  875. </value>
  876. </entry>
  877. <entry>
  878. <key>Avro schema</key>
  879. <value>
  880. <name>Avro schema</name>
  881. </value>
  882. </entry>
  883. </descriptors>
  884. <executionNode>ALL</executionNode>
  885. <lossTolerant>false</lossTolerant>
  886. <penaltyDuration>30 sec</penaltyDuration>
  887. <properties>
  888. <entry>
  889. <key>JSON container options</key>
  890. <value>array</value>
  891. </entry>
  892. <entry>
  893. <key>Wrap Single Record</key>
  894. <value>false</value>
  895. </entry>
  896. <entry>
  897. <key>Avro schema</key>
  898. </entry>
  899. </properties>
  900. <runDurationMillis>0</runDurationMillis>
  901. <schedulingPeriod>0 sec</schedulingPeriod>
  902. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  903. <yieldDuration>1 sec</yieldDuration>
  904. </config>
  905. <name>ConvertAvroToJSON</name>
  906. <relationships>
  907. <autoTerminate>true</autoTerminate>
  908. <name>failure</name>
  909. </relationships>
  910. <relationships>
  911. <autoTerminate>false</autoTerminate>
  912. <name>success</name>
  913. </relationships>
  914. <style></style>
  915. <type>org.apache.nifi.processors.avro.ConvertAvroToJSON</type>
  916. </processors>
  917. <processors>
  918. <id>ca0aff29-42b6-3979-0000-000000000000</id>
  919. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  920. <position>
  921. <x>6.107256693939576</x>
  922. <y>638.4573522838762</y>
  923. </position>
  924. <bundle>
  925. <artifact>nifi-avro-nar</artifact>
  926. <group>org.apache.nifi</group>
  927. <version>1.2.0-SNAPSHOT</version>
  928. </bundle>
  929. <config>
  930. <bulletinLevel>WARN</bulletinLevel>
  931. <comments></comments>
  932. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  933. <descriptors>
  934. <entry>
  935. <key>JSON container options</key>
  936. <value>
  937. <name>JSON container options</name>
  938. </value>
  939. </entry>
  940. <entry>
  941. <key>Wrap Single Record</key>
  942. <value>
  943. <name>Wrap Single Record</name>
  944. </value>
  945. </entry>
  946. <entry>
  947. <key>Avro schema</key>
  948. <value>
  949. <name>Avro schema</name>
  950. </value>
  951. </entry>
  952. </descriptors>
  953. <executionNode>ALL</executionNode>
  954. <lossTolerant>false</lossTolerant>
  955. <penaltyDuration>30 sec</penaltyDuration>
  956. <properties>
  957. <entry>
  958. <key>JSON container options</key>
  959. <value>array</value>
  960. </entry>
  961. <entry>
  962. <key>Wrap Single Record</key>
  963. <value>false</value>
  964. </entry>
  965. <entry>
  966. <key>Avro schema</key>
  967. </entry>
  968. </properties>
  969. <runDurationMillis>0</runDurationMillis>
  970. <schedulingPeriod>0 sec</schedulingPeriod>
  971. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  972. <yieldDuration>1 sec</yieldDuration>
  973. </config>
  974. <name>ConvertAvroToJSON</name>
  975. <relationships>
  976. <autoTerminate>true</autoTerminate>
  977. <name>failure</name>
  978. </relationships>
  979. <relationships>
  980. <autoTerminate>false</autoTerminate>
  981. <name>success</name>
  982. </relationships>
  983. <style></style>
  984. <type>org.apache.nifi.processors.avro.ConvertAvroToJSON</type>
  985. </processors>
  986. <processors>
  987. <id>e372ac4b-0e15-3e07-0000-000000000000</id>
  988. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  989. <position>
  990. <x>0.0</x>
  991. <y>433.39878011002014</y>
  992. </position>
  993. <bundle>
  994. <artifact>nifi-standard-nar</artifact>
  995. <group>org.apache.nifi</group>
  996. <version>1.2.0-SNAPSHOT</version>
  997. </bundle>
  998. <config>
  999. <bulletinLevel>WARN</bulletinLevel>
  1000. <comments></comments>
  1001. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1002. <descriptors>
  1003. <entry>
  1004. <key>Record Reader</key>
  1005. <value>
  1006. <identifiesControllerService>org.apache.nifi.serialization.RowRecordReaderFactory</identifiesControllerService>
  1007. <name>Record Reader</name>
  1008. </value>
  1009. </entry>
  1010. <entry>
  1011. <key>Record Writer</key>
  1012. <value>
  1013. <identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService>
  1014. <name>Record Writer</name>
  1015. </value>
  1016. </entry>
  1017. </descriptors>
  1018. <executionNode>ALL</executionNode>
  1019. <lossTolerant>false</lossTolerant>
  1020. <penaltyDuration>30 sec</penaltyDuration>
  1021. <properties>
  1022. <entry>
  1023. <key>Record Reader</key>
  1024. <value>0e095f2c-1d29-3816-0000-000000000000</value>
  1025. </entry>
  1026. <entry>
  1027. <key>Record Writer</key>
  1028. <value>d56dac0d-dfa2-3e17-0000-000000000000</value>
  1029. </entry>
  1030. </properties>
  1031. <runDurationMillis>0</runDurationMillis>
  1032. <schedulingPeriod>0 sec</schedulingPeriod>
  1033. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1034. <yieldDuration>1 sec</yieldDuration>
  1035. </config>
  1036. <name>ConvertRecord</name>
  1037. <relationships>
  1038. <autoTerminate>true</autoTerminate>
  1039. <name>failure</name>
  1040. </relationships>
  1041. <relationships>
  1042. <autoTerminate>false</autoTerminate>
  1043. <name>success</name>
  1044. </relationships>
  1045. <style></style>
  1046. <type>org.apache.nifi.processors.standard.ConvertRecord</type>
  1047. </processors>
  1048. <processors>
  1049. <id>e7432dc4-d030-325c-0000-000000000000</id>
  1050. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  1051. <position>
  1052. <x>800.5780779853989</x>
  1053. <y>215.72693351357316</y>
  1054. </position>
  1055. <bundle>
  1056. <artifact>nifi-update-attribute-nar</artifact>
  1057. <group>org.apache.nifi</group>
  1058. <version>1.2.0-SNAPSHOT</version>
  1059. </bundle>
  1060. <config>
  1061. <bulletinLevel>WARN</bulletinLevel>
  1062. <comments></comments>
  1063. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1064. <descriptors>
  1065. <entry>
  1066. <key>Delete Attributes Expression</key>
  1067. <value>
  1068. <name>Delete Attributes Expression</name>
  1069. </value>
  1070. </entry>
  1071. <entry>
  1072. <key>Store State</key>
  1073. <value>
  1074. <name>Store State</name>
  1075. </value>
  1076. </entry>
  1077. <entry>
  1078. <key>Stateful Variables Initial Value</key>
  1079. <value>
  1080. <name>Stateful Variables Initial Value</name>
  1081. </value>
  1082. </entry>
  1083. <entry>
  1084. <key>schema.name</key>
  1085. <value>
  1086. <name>schema.name</name>
  1087. </value>
  1088. </entry>
  1089. </descriptors>
  1090. <executionNode>ALL</executionNode>
  1091. <lossTolerant>false</lossTolerant>
  1092. <penaltyDuration>30 sec</penaltyDuration>
  1093. <properties>
  1094. <entry>
  1095. <key>Delete Attributes Expression</key>
  1096. </entry>
  1097. <entry>
  1098. <key>Store State</key>
  1099. <value>Do not store state</value>
  1100. </entry>
  1101. <entry>
  1102. <key>Stateful Variables Initial Value</key>
  1103. </entry>
  1104. <entry>
  1105. <key>schema.name</key>
  1106. <value>user</value>
  1107. </entry>
  1108. </properties>
  1109. <runDurationMillis>0</runDurationMillis>
  1110. <schedulingPeriod>0 sec</schedulingPeriod>
  1111. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1112. <yieldDuration>1 sec</yieldDuration>
  1113. </config>
  1114. <name>UpdateAttribute</name>
  1115. <relationships>
  1116. <autoTerminate>false</autoTerminate>
  1117. <name>success</name>
  1118. </relationships>
  1119. <style></style>
  1120. <type>org.apache.nifi.processors.attributes.UpdateAttribute</type>
  1121. </processors>
  1122. <processors>
  1123. <id>20004fbd-20c9-3a44-0000-000000000000</id>
  1124. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  1125. <position>
  1126. <x>798.8835377826341</x>
  1127. <y>0.0</y>
  1128. </position>
  1129. <bundle>
  1130. <artifact>nifi-standard-nar</artifact>
  1131. <group>org.apache.nifi</group>
  1132. <version>1.2.0-SNAPSHOT</version>
  1133. </bundle>
  1134. <config>
  1135. <bulletinLevel>WARN</bulletinLevel>
  1136. <comments></comments>
  1137. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1138. <descriptors>
  1139. <entry>
  1140. <key>Database Connection Pooling Service</key>
  1141. <value>
  1142. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  1143. <name>Database Connection Pooling Service</name>
  1144. </value>
  1145. </entry>
  1146. <entry>
  1147. <key>db-fetch-db-type</key>
  1148. <value>
  1149. <name>db-fetch-db-type</name>
  1150. </value>
  1151. </entry>
  1152. <entry>
  1153. <key>Table Name</key>
  1154. <value>
  1155. <name>Table Name</name>
  1156. </value>
  1157. </entry>
  1158. <entry>
  1159. <key>Columns to Return</key>
  1160. <value>
  1161. <name>Columns to Return</name>
  1162. </value>
  1163. </entry>
  1164. <entry>
  1165. <key>Maximum-value Columns</key>
  1166. <value>
  1167. <name>Maximum-value Columns</name>
  1168. </value>
  1169. </entry>
  1170. <entry>
  1171. <key>Max Wait Time</key>
  1172. <value>
  1173. <name>Max Wait Time</name>
  1174. </value>
  1175. </entry>
  1176. <entry>
  1177. <key>Fetch Size</key>
  1178. <value>
  1179. <name>Fetch Size</name>
  1180. </value>
  1181. </entry>
  1182. <entry>
  1183. <key>qdbt-max-rows</key>
  1184. <value>
  1185. <name>qdbt-max-rows</name>
  1186. </value>
  1187. </entry>
  1188. <entry>
  1189. <key>qdbt-max-frags</key>
  1190. <value>
  1191. <name>qdbt-max-frags</name>
  1192. </value>
  1193. </entry>
  1194. <entry>
  1195. <key>dbf-normalize</key>
  1196. <value>
  1197. <name>dbf-normalize</name>
  1198. </value>
  1199. </entry>
  1200. </descriptors>
  1201. <executionNode>ALL</executionNode>
  1202. <lossTolerant>false</lossTolerant>
  1203. <penaltyDuration>30 sec</penaltyDuration>
  1204. <properties>
  1205. <entry>
  1206. <key>Database Connection Pooling Service</key>
  1207. <value>d33e98e7-978b-3662-0000-000000000000</value>
  1208. </entry>
  1209. <entry>
  1210. <key>db-fetch-db-type</key>
  1211. <value>Generic</value>
  1212. </entry>
  1213. <entry>
  1214. <key>Table Name</key>
  1215. <value>avrotest</value>
  1216. </entry>
  1217. <entry>
  1218. <key>Columns to Return</key>
  1219. </entry>
  1220. <entry>
  1221. <key>Maximum-value Columns</key>
  1222. </entry>
  1223. <entry>
  1224. <key>Max Wait Time</key>
  1225. <value>0 seconds</value>
  1226. </entry>
  1227. <entry>
  1228. <key>Fetch Size</key>
  1229. <value>0</value>
  1230. </entry>
  1231. <entry>
  1232. <key>qdbt-max-rows</key>
  1233. <value>0</value>
  1234. </entry>
  1235. <entry>
  1236. <key>qdbt-max-frags</key>
  1237. <value>0</value>
  1238. </entry>
  1239. <entry>
  1240. <key>dbf-normalize</key>
  1241. <value>false</value>
  1242. </entry>
  1243. </properties>
  1244. <runDurationMillis>0</runDurationMillis>
  1245. <schedulingPeriod>0 sec</schedulingPeriod>
  1246. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1247. <yieldDuration>1 sec</yieldDuration>
  1248. </config>
  1249. <name>QueryDatabaseTable</name>
  1250. <relationships>
  1251. <autoTerminate>false</autoTerminate>
  1252. <name>success</name>
  1253. </relationships>
  1254. <style></style>
  1255. <type>org.apache.nifi.processors.standard.QueryDatabaseTable</type>
  1256. </processors>
  1257. <processors>
  1258. <id>34ab082f-e5df-3717-0000-000000000000</id>
  1259. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  1260. <position>
  1261. <x>518.9418029785156</x>
  1262. <y>433.1519386793561</y>
  1263. </position>
  1264. <bundle>
  1265. <artifact>nifi-standard-nar</artifact>
  1266. <group>org.apache.nifi</group>
  1267. <version>1.2.0-SNAPSHOT</version>
  1268. </bundle>
  1269. <config>
  1270. <bulletinLevel>WARN</bulletinLevel>
  1271. <comments></comments>
  1272. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1273. <descriptors>
  1274. <entry>
  1275. <key>Record Reader</key>
  1276. <value>
  1277. <identifiesControllerService>org.apache.nifi.serialization.RowRecordReaderFactory</identifiesControllerService>
  1278. <name>Record Reader</name>
  1279. </value>
  1280. </entry>
  1281. <entry>
  1282. <key>Record Writer</key>
  1283. <value>
  1284. <identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService>
  1285. <name>Record Writer</name>
  1286. </value>
  1287. </entry>
  1288. </descriptors>
  1289. <executionNode>ALL</executionNode>
  1290. <lossTolerant>false</lossTolerant>
  1291. <penaltyDuration>30 sec</penaltyDuration>
  1292. <properties>
  1293. <entry>
  1294. <key>Record Reader</key>
  1295. <value>f0788303-8156-3d11-0000-000000000000</value>
  1296. </entry>
  1297. <entry>
  1298. <key>Record Writer</key>
  1299. <value>d37bd3a4-50d6-369a-0000-000000000000</value>
  1300. </entry>
  1301. </properties>
  1302. <runDurationMillis>0</runDurationMillis>
  1303. <schedulingPeriod>0 sec</schedulingPeriod>
  1304. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1305. <yieldDuration>1 sec</yieldDuration>
  1306. </config>
  1307. <name>ConvertRecord</name>
  1308. <relationships>
  1309. <autoTerminate>true</autoTerminate>
  1310. <name>failure</name>
  1311. </relationships>
  1312. <relationships>
  1313. <autoTerminate>false</autoTerminate>
  1314. <name>success</name>
  1315. </relationships>
  1316. <style></style>
  1317. <type>org.apache.nifi.processors.standard.ConvertRecord</type>
  1318. </processors>
  1319. <processors>
  1320. <id>50380fd4-2678-3551-0000-000000000000</id>
  1321. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  1322. <position>
  1323. <x>1188.4174499511719</x>
  1324. <y>699.2382423902936</y>
  1325. </position>
  1326. <bundle>
  1327. <artifact>nifi-standard-nar</artifact>
  1328. <group>org.apache.nifi</group>
  1329. <version>1.2.0-SNAPSHOT</version>
  1330. </bundle>
  1331. <config>
  1332. <bulletinLevel>WARN</bulletinLevel>
  1333. <comments></comments>
  1334. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1335. <descriptors>
  1336. <entry>
  1337. <key>Record Reader</key>
  1338. <value>
  1339. <identifiesControllerService>org.apache.nifi.serialization.RowRecordReaderFactory</identifiesControllerService>
  1340. <name>Record Reader</name>
  1341. </value>
  1342. </entry>
  1343. <entry>
  1344. <key>Record Writer</key>
  1345. <value>
  1346. <identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService>
  1347. <name>Record Writer</name>
  1348. </value>
  1349. </entry>
  1350. </descriptors>
  1351. <executionNode>ALL</executionNode>
  1352. <lossTolerant>false</lossTolerant>
  1353. <penaltyDuration>30 sec</penaltyDuration>
  1354. <properties>
  1355. <entry>
  1356. <key>Record Reader</key>
  1357. <value>0e095f2c-1d29-3816-0000-000000000000</value>
  1358. </entry>
  1359. <entry>
  1360. <key>Record Writer</key>
  1361. <value>adc75919-ace6-381a-0000-000000000000</value>
  1362. </entry>
  1363. </properties>
  1364. <runDurationMillis>0</runDurationMillis>
  1365. <schedulingPeriod>0 sec</schedulingPeriod>
  1366. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1367. <yieldDuration>1 sec</yieldDuration>
  1368. </config>
  1369. <name>ConvertRecord</name>
  1370. <relationships>
  1371. <autoTerminate>true</autoTerminate>
  1372. <name>failure</name>
  1373. </relationships>
  1374. <relationships>
  1375. <autoTerminate>false</autoTerminate>
  1376. <name>success</name>
  1377. </relationships>
  1378. <style></style>
  1379. <type>org.apache.nifi.processors.standard.ConvertRecord</type>
  1380. </processors>
  1381. <processors>
  1382. <id>7ff23431-7ac9-348b-0000-000000000000</id>
  1383. <parentGroupId>868f7eec-2b0e-352b-0000-000000000000</parentGroupId>
  1384. <position>
  1385. <x>7.201002332435451</x>
  1386. <y>40.58277049028666</y>
  1387. </position>
  1388. <bundle>
  1389. <artifact>nifi-standard-nar</artifact>
  1390. <group>org.apache.nifi</group>
  1391. <version>1.2.0-SNAPSHOT</version>
  1392. </bundle>
  1393. <config>
  1394. <bulletinLevel>WARN</bulletinLevel>
  1395. <comments></comments>
  1396. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  1397. <descriptors>
  1398. <entry>
  1399. <key>File Size</key>
  1400. <value>
  1401. <name>File Size</name>
  1402. </value>
  1403. </entry>
  1404. <entry>
  1405. <key>Batch Size</key>
  1406. <value>
  1407. <name>Batch Size</name>
  1408. </value>
  1409. </entry>
  1410. <entry>
  1411. <key>Data Format</key>
  1412. <value>
  1413. <name>Data Format</name>
  1414. </value>
  1415. </entry>
  1416. <entry>
  1417. <key>Unique FlowFiles</key>
  1418. <value>
  1419. <name>Unique FlowFiles</name>
  1420. </value>
  1421. </entry>
  1422. <entry>
  1423. <key>generate-ff-custom-text</key>
  1424. <value>
  1425. <name>generate-ff-custom-text</name>
  1426. </value>
  1427. </entry>
  1428. </descriptors>
  1429. <executionNode>ALL</executionNode>
  1430. <lossTolerant>false</lossTolerant>
  1431. <penaltyDuration>30 sec</penaltyDuration>
  1432. <properties>
  1433. <entry>
  1434. <key>File Size</key>
  1435. <value>0B</value>
  1436. </entry>
  1437. <entry>
  1438. <key>Batch Size</key>
  1439. <value>1</value>
  1440. </entry>
  1441. <entry>
  1442. <key>Data Format</key>
  1443. <value>Text</value>
  1444. </entry>
  1445. <entry>
  1446. <key>Unique FlowFiles</key>
  1447. <value>false</value>
  1448. </entry>
  1449. <entry>
  1450. <key>generate-ff-custom-text</key>
  1451. <value>[
  1452. {"id": 2, "name": "Matt"},
  1453. {"id": 1, "name": "Burgess"}
  1454. ]</value>
  1455. </entry>
  1456. </properties>
  1457. <runDurationMillis>0</runDurationMillis>
  1458. <schedulingPeriod>30 sec</schedulingPeriod>
  1459. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  1460. <yieldDuration>1 sec</yieldDuration>
  1461. </config>
  1462. <name>GenerateFlowFile</name>
  1463. <relationships>
  1464. <autoTerminate>false</autoTerminate>
  1465. <name>success</name>
  1466. </relationships>
  1467. <style></style>
  1468. <type>org.apache.nifi.processors.standard.GenerateFlowFile</type>
  1469. </processors>
  1470. </snippet>
  1471. <timestamp>04/18/2017 10:19:58 EDT</timestamp>
  1472. </template>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement