Advertisement
Guest User

Untitled

a guest
Jun 12th, 2017
118
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 22.89 KB | None | 0 0
  1. <?xml version="1.0" ?>
  2. <template encoding-version="1.1">
  3. <description></description>
  4. <groupId>1e8778a8-015c-1000-c747-8273276bab45</groupId>
  5. <name>MySQL Decimal</name>
  6. <snippet>
  7. <processGroups>
  8. <id>fcff8588-6cae-364b-0000-000000000000</id>
  9. <parentGroupId>5454b790-94fe-3e28-0000-000000000000</parentGroupId>
  10. <position>
  11. <x>0.0</x>
  12. <y>0.0</y>
  13. </position>
  14. <comments></comments>
  15. <contents>
  16. <connections>
  17. <id>c7cc273d-5b73-3940-0000-000000000000</id>
  18. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  19. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  20. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  21. <destination>
  22. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  23. <id>137b0f09-d80a-3c68-0000-000000000000</id>
  24. <type>PROCESSOR</type>
  25. </destination>
  26. <flowFileExpiration>0 sec</flowFileExpiration>
  27. <labelIndex>0</labelIndex>
  28. <name></name>
  29. <selectedRelationships>failure</selectedRelationships>
  30. <source>
  31. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  32. <id>60bec32b-990e-3aaf-0000-000000000000</id>
  33. <type>PROCESSOR</type>
  34. </source>
  35. <zIndex>0</zIndex>
  36. </connections>
  37. <connections>
  38. <id>c9ba4afc-77c3-306e-0000-000000000000</id>
  39. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  40. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  41. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  42. <destination>
  43. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  44. <id>d870d851-d95d-3690-0000-000000000000</id>
  45. <type>PROCESSOR</type>
  46. </destination>
  47. <flowFileExpiration>0 sec</flowFileExpiration>
  48. <labelIndex>1</labelIndex>
  49. <name></name>
  50. <selectedRelationships>success</selectedRelationships>
  51. <source>
  52. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  53. <id>60bec32b-990e-3aaf-0000-000000000000</id>
  54. <type>PROCESSOR</type>
  55. </source>
  56. <zIndex>0</zIndex>
  57. </connections>
  58. <connections>
  59. <id>cfb5dac9-53cf-360a-0000-000000000000</id>
  60. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  61. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  62. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  63. <destination>
  64. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  65. <id>137b0f09-d80a-3c68-0000-000000000000</id>
  66. <type>PROCESSOR</type>
  67. </destination>
  68. <flowFileExpiration>0 sec</flowFileExpiration>
  69. <labelIndex>1</labelIndex>
  70. <name></name>
  71. <selectedRelationships>success</selectedRelationships>
  72. <source>
  73. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  74. <id>d870d851-d95d-3690-0000-000000000000</id>
  75. <type>PROCESSOR</type>
  76. </source>
  77. <zIndex>0</zIndex>
  78. </connections>
  79. <connections>
  80. <id>ff0a120b-cf1c-39c7-0000-000000000000</id>
  81. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  82. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  83. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  84. <bends>
  85. <x>1075.0</x>
  86. <y>913.0</y>
  87. </bends>
  88. <destination>
  89. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  90. <id>137b0f09-d80a-3c68-0000-000000000000</id>
  91. <type>PROCESSOR</type>
  92. </destination>
  93. <flowFileExpiration>0 sec</flowFileExpiration>
  94. <labelIndex>1</labelIndex>
  95. <name></name>
  96. <selectedRelationships>failure</selectedRelationships>
  97. <selectedRelationships>retry</selectedRelationships>
  98. <source>
  99. <groupId>fcff8588-6cae-364b-0000-000000000000</groupId>
  100. <id>d870d851-d95d-3690-0000-000000000000</id>
  101. <type>PROCESSOR</type>
  102. </source>
  103. <zIndex>0</zIndex>
  104. </connections>
  105. <controllerServices>
  106. <id>1af83330-0038-343b-0000-000000000000</id>
  107. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  108. <bundle>
  109. <artifact>nifi-dbcp-service-nar</artifact>
  110. <group>org.apache.nifi</group>
  111. <version>1.4.0-SNAPSHOT</version>
  112. </bundle>
  113. <comments></comments>
  114. <descriptors>
  115. <entry>
  116. <key>Database Connection URL</key>
  117. <value>
  118. <name>Database Connection URL</name>
  119. </value>
  120. </entry>
  121. <entry>
  122. <key>Database Driver Class Name</key>
  123. <value>
  124. <name>Database Driver Class Name</name>
  125. </value>
  126. </entry>
  127. <entry>
  128. <key>database-driver-locations</key>
  129. <value>
  130. <name>database-driver-locations</name>
  131. </value>
  132. </entry>
  133. <entry>
  134. <key>Database User</key>
  135. <value>
  136. <name>Database User</name>
  137. </value>
  138. </entry>
  139. <entry>
  140. <key>Password</key>
  141. <value>
  142. <name>Password</name>
  143. </value>
  144. </entry>
  145. <entry>
  146. <key>Max Wait Time</key>
  147. <value>
  148. <name>Max Wait Time</name>
  149. </value>
  150. </entry>
  151. <entry>
  152. <key>Max Total Connections</key>
  153. <value>
  154. <name>Max Total Connections</name>
  155. </value>
  156. </entry>
  157. <entry>
  158. <key>Validation-query</key>
  159. <value>
  160. <name>Validation-query</name>
  161. </value>
  162. </entry>
  163. </descriptors>
  164. <name>DBCPConnectionPool</name>
  165. <persistsState>false</persistsState>
  166. <properties>
  167. <entry>
  168. <key>Database Connection URL</key>
  169. <value>jdbc:mysql://192.168.99.100:3306/nifi_test</value>
  170. </entry>
  171. <entry>
  172. <key>Database Driver Class Name</key>
  173. <value>com.mysql.jdbc.Driver</value>
  174. </entry>
  175. <entry>
  176. <key>database-driver-locations</key>
  177. <value>/Users/koji/Downloads/mysql-connector-java-5.1.41/mysql-connector-java-5.1.41-bin.jar</value>
  178. </entry>
  179. <entry>
  180. <key>Database User</key>
  181. <value>root</value>
  182. </entry>
  183. <entry>
  184. <key>Password</key>
  185. </entry>
  186. <entry>
  187. <key>Max Wait Time</key>
  188. </entry>
  189. <entry>
  190. <key>Max Total Connections</key>
  191. </entry>
  192. <entry>
  193. <key>Validation-query</key>
  194. </entry>
  195. </properties>
  196. <state>ENABLED</state>
  197. <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
  198. </controllerServices>
  199. <controllerServices>
  200. <id>2fbf4c12-5ee6-34c5-0000-000000000000</id>
  201. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  202. <bundle>
  203. <artifact>nifi-record-serialization-services-nar</artifact>
  204. <group>org.apache.nifi</group>
  205. <version>1.4.0-SNAPSHOT</version>
  206. </bundle>
  207. <comments></comments>
  208. <descriptors>
  209. <entry>
  210. <key>schema-access-strategy</key>
  211. <value>
  212. <name>schema-access-strategy</name>
  213. </value>
  214. </entry>
  215. <entry>
  216. <key>schema-registry</key>
  217. <value>
  218. <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
  219. <name>schema-registry</name>
  220. </value>
  221. </entry>
  222. <entry>
  223. <key>schema-name</key>
  224. <value>
  225. <name>schema-name</name>
  226. </value>
  227. </entry>
  228. <entry>
  229. <key>schema-text</key>
  230. <value>
  231. <name>schema-text</name>
  232. </value>
  233. </entry>
  234. </descriptors>
  235. <name>AvroReader</name>
  236. <persistsState>false</persistsState>
  237. <properties>
  238. <entry>
  239. <key>schema-access-strategy</key>
  240. </entry>
  241. <entry>
  242. <key>schema-registry</key>
  243. </entry>
  244. <entry>
  245. <key>schema-name</key>
  246. </entry>
  247. <entry>
  248. <key>schema-text</key>
  249. </entry>
  250. </properties>
  251. <state>ENABLED</state>
  252. <type>org.apache.nifi.avro.AvroReader</type>
  253. </controllerServices>
  254. <processors>
  255. <id>d870d851-d95d-3690-0000-000000000000</id>
  256. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  257. <position>
  258. <x>936.9999962089732</x>
  259. <y>661.9999942997559</y>
  260. </position>
  261. <bundle>
  262. <artifact>nifi-standard-nar</artifact>
  263. <group>org.apache.nifi</group>
  264. <version>1.4.0-SNAPSHOT</version>
  265. </bundle>
  266. <config>
  267. <bulletinLevel>WARN</bulletinLevel>
  268. <comments></comments>
  269. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  270. <descriptors>
  271. <entry>
  272. <key>put-db-record-record-reader</key>
  273. <value>
  274. <identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService>
  275. <name>put-db-record-record-reader</name>
  276. </value>
  277. </entry>
  278. <entry>
  279. <key>put-db-record-statement-type</key>
  280. <value>
  281. <name>put-db-record-statement-type</name>
  282. </value>
  283. </entry>
  284. <entry>
  285. <key>put-db-record-dcbp-service</key>
  286. <value>
  287. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  288. <name>put-db-record-dcbp-service</name>
  289. </value>
  290. </entry>
  291. <entry>
  292. <key>put-db-record-catalog-name</key>
  293. <value>
  294. <name>put-db-record-catalog-name</name>
  295. </value>
  296. </entry>
  297. <entry>
  298. <key>put-db-record-schema-name</key>
  299. <value>
  300. <name>put-db-record-schema-name</name>
  301. </value>
  302. </entry>
  303. <entry>
  304. <key>put-db-record-table-name</key>
  305. <value>
  306. <name>put-db-record-table-name</name>
  307. </value>
  308. </entry>
  309. <entry>
  310. <key>put-db-record-translate-field-names</key>
  311. <value>
  312. <name>put-db-record-translate-field-names</name>
  313. </value>
  314. </entry>
  315. <entry>
  316. <key>put-db-record-unmatched-field-behavior</key>
  317. <value>
  318. <name>put-db-record-unmatched-field-behavior</name>
  319. </value>
  320. </entry>
  321. <entry>
  322. <key>put-db-record-unmatched-column-behavior</key>
  323. <value>
  324. <name>put-db-record-unmatched-column-behavior</name>
  325. </value>
  326. </entry>
  327. <entry>
  328. <key>put-db-record-update-keys</key>
  329. <value>
  330. <name>put-db-record-update-keys</name>
  331. </value>
  332. </entry>
  333. <entry>
  334. <key>put-db-record-field-containing-sql</key>
  335. <value>
  336. <name>put-db-record-field-containing-sql</name>
  337. </value>
  338. </entry>
  339. <entry>
  340. <key>put-db-record-quoted-identifiers</key>
  341. <value>
  342. <name>put-db-record-quoted-identifiers</name>
  343. </value>
  344. </entry>
  345. <entry>
  346. <key>put-db-record-quoted-table-identifiers</key>
  347. <value>
  348. <name>put-db-record-quoted-table-identifiers</name>
  349. </value>
  350. </entry>
  351. <entry>
  352. <key>put-db-record-query-timeout</key>
  353. <value>
  354. <name>put-db-record-query-timeout</name>
  355. </value>
  356. </entry>
  357. <entry>
  358. <key>rollback-on-failure</key>
  359. <value>
  360. <name>rollback-on-failure</name>
  361. </value>
  362. </entry>
  363. </descriptors>
  364. <executionNode>ALL</executionNode>
  365. <lossTolerant>false</lossTolerant>
  366. <penaltyDuration>30 sec</penaltyDuration>
  367. <properties>
  368. <entry>
  369. <key>put-db-record-record-reader</key>
  370. <value>2fbf4c12-5ee6-34c5-0000-000000000000</value>
  371. </entry>
  372. <entry>
  373. <key>put-db-record-statement-type</key>
  374. <value>INSERT</value>
  375. </entry>
  376. <entry>
  377. <key>put-db-record-dcbp-service</key>
  378. <value>1af83330-0038-343b-0000-000000000000</value>
  379. </entry>
  380. <entry>
  381. <key>put-db-record-catalog-name</key>
  382. </entry>
  383. <entry>
  384. <key>put-db-record-schema-name</key>
  385. </entry>
  386. <entry>
  387. <key>put-db-record-table-name</key>
  388. <value>decimal_2</value>
  389. </entry>
  390. <entry>
  391. <key>put-db-record-translate-field-names</key>
  392. <value>true</value>
  393. </entry>
  394. <entry>
  395. <key>put-db-record-unmatched-field-behavior</key>
  396. <value>Ignore Unmatched Fields</value>
  397. </entry>
  398. <entry>
  399. <key>put-db-record-unmatched-column-behavior</key>
  400. <value>Fail on Unmatched Columns</value>
  401. </entry>
  402. <entry>
  403. <key>put-db-record-update-keys</key>
  404. </entry>
  405. <entry>
  406. <key>put-db-record-field-containing-sql</key>
  407. </entry>
  408. <entry>
  409. <key>put-db-record-quoted-identifiers</key>
  410. <value>false</value>
  411. </entry>
  412. <entry>
  413. <key>put-db-record-quoted-table-identifiers</key>
  414. <value>false</value>
  415. </entry>
  416. <entry>
  417. <key>put-db-record-query-timeout</key>
  418. <value>0 seconds</value>
  419. </entry>
  420. <entry>
  421. <key>rollback-on-failure</key>
  422. <value>false</value>
  423. </entry>
  424. </properties>
  425. <runDurationMillis>0</runDurationMillis>
  426. <schedulingPeriod>0 sec</schedulingPeriod>
  427. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  428. <yieldDuration>1 sec</yieldDuration>
  429. </config>
  430. <name>PutDatabaseRecord</name>
  431. <relationships>
  432. <autoTerminate>false</autoTerminate>
  433. <name>failure</name>
  434. </relationships>
  435. <relationships>
  436. <autoTerminate>false</autoTerminate>
  437. <name>retry</name>
  438. </relationships>
  439. <relationships>
  440. <autoTerminate>false</autoTerminate>
  441. <name>success</name>
  442. </relationships>
  443. <style></style>
  444. <type>org.apache.nifi.processors.standard.PutDatabaseRecord</type>
  445. </processors>
  446. <processors>
  447. <id>137b0f09-d80a-3c68-0000-000000000000</id>
  448. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  449. <position>
  450. <x>343.9536705253795</x>
  451. <y>806.0963077763184</y>
  452. </position>
  453. <bundle>
  454. <artifact>nifi-standard-nar</artifact>
  455. <group>org.apache.nifi</group>
  456. <version>1.4.0-SNAPSHOT</version>
  457. </bundle>
  458. <config>
  459. <bulletinLevel>WARN</bulletinLevel>
  460. <comments></comments>
  461. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  462. <descriptors>
  463. <entry>
  464. <key>Log Level</key>
  465. <value>
  466. <name>Log Level</name>
  467. </value>
  468. </entry>
  469. <entry>
  470. <key>Log Payload</key>
  471. <value>
  472. <name>Log Payload</name>
  473. </value>
  474. </entry>
  475. <entry>
  476. <key>Attributes to Log</key>
  477. <value>
  478. <name>Attributes to Log</name>
  479. </value>
  480. </entry>
  481. <entry>
  482. <key>Attributes to Ignore</key>
  483. <value>
  484. <name>Attributes to Ignore</name>
  485. </value>
  486. </entry>
  487. <entry>
  488. <key>Log prefix</key>
  489. <value>
  490. <name>Log prefix</name>
  491. </value>
  492. </entry>
  493. </descriptors>
  494. <executionNode>ALL</executionNode>
  495. <lossTolerant>false</lossTolerant>
  496. <penaltyDuration>30 sec</penaltyDuration>
  497. <properties>
  498. <entry>
  499. <key>Log Level</key>
  500. <value>info</value>
  501. </entry>
  502. <entry>
  503. <key>Log Payload</key>
  504. <value>false</value>
  505. </entry>
  506. <entry>
  507. <key>Attributes to Log</key>
  508. </entry>
  509. <entry>
  510. <key>Attributes to Ignore</key>
  511. </entry>
  512. <entry>
  513. <key>Log prefix</key>
  514. </entry>
  515. </properties>
  516. <runDurationMillis>0</runDurationMillis>
  517. <schedulingPeriod>0 sec</schedulingPeriod>
  518. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  519. <yieldDuration>1 sec</yieldDuration>
  520. </config>
  521. <name>LogAttribute</name>
  522. <relationships>
  523. <autoTerminate>false</autoTerminate>
  524. <name>success</name>
  525. </relationships>
  526. <style></style>
  527. <type>org.apache.nifi.processors.standard.LogAttribute</type>
  528. </processors>
  529. <processors>
  530. <id>60bec32b-990e-3aaf-0000-000000000000</id>
  531. <parentGroupId>fcff8588-6cae-364b-0000-000000000000</parentGroupId>
  532. <position>
  533. <x>570.9999962089732</x>
  534. <y>281.99999429975594</y>
  535. </position>
  536. <bundle>
  537. <artifact>nifi-standard-nar</artifact>
  538. <group>org.apache.nifi</group>
  539. <version>1.4.0-SNAPSHOT</version>
  540. </bundle>
  541. <config>
  542. <bulletinLevel>WARN</bulletinLevel>
  543. <comments></comments>
  544. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  545. <descriptors>
  546. <entry>
  547. <key>Database Connection Pooling Service</key>
  548. <value>
  549. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  550. <name>Database Connection Pooling Service</name>
  551. </value>
  552. </entry>
  553. <entry>
  554. <key>SQL select query</key>
  555. <value>
  556. <name>SQL select query</name>
  557. </value>
  558. </entry>
  559. <entry>
  560. <key>Max Wait Time</key>
  561. <value>
  562. <name>Max Wait Time</name>
  563. </value>
  564. </entry>
  565. <entry>
  566. <key>dbf-normalize</key>
  567. <value>
  568. <name>dbf-normalize</name>
  569. </value>
  570. </entry>
  571. <entry>
  572. <key>dbf-user-logical-types</key>
  573. <value>
  574. <name>dbf-user-logical-types</name>
  575. </value>
  576. </entry>
  577. <entry>
  578. <key>dbf-default-precision</key>
  579. <value>
  580. <name>dbf-default-precision</name>
  581. </value>
  582. </entry>
  583. <entry>
  584. <key>dbf-default-scale</key>
  585. <value>
  586. <name>dbf-default-scale</name>
  587. </value>
  588. </entry>
  589. </descriptors>
  590. <executionNode>ALL</executionNode>
  591. <lossTolerant>false</lossTolerant>
  592. <penaltyDuration>30 sec</penaltyDuration>
  593. <properties>
  594. <entry>
  595. <key>Database Connection Pooling Service</key>
  596. <value>1af83330-0038-343b-0000-000000000000</value>
  597. </entry>
  598. <entry>
  599. <key>SQL select query</key>
  600. <value>select * from decimal_1</value>
  601. </entry>
  602. <entry>
  603. <key>Max Wait Time</key>
  604. <value>0 seconds</value>
  605. </entry>
  606. <entry>
  607. <key>dbf-normalize</key>
  608. <value>false</value>
  609. </entry>
  610. <entry>
  611. <key>dbf-user-logical-types</key>
  612. <value>true</value>
  613. </entry>
  614. <entry>
  615. <key>dbf-default-precision</key>
  616. <value>10</value>
  617. </entry>
  618. <entry>
  619. <key>dbf-default-scale</key>
  620. <value>0</value>
  621. </entry>
  622. </properties>
  623. <runDurationMillis>0</runDurationMillis>
  624. <schedulingPeriod>1d</schedulingPeriod>
  625. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  626. <yieldDuration>1 sec</yieldDuration>
  627. </config>
  628. <name>ExecuteSQL</name>
  629. <relationships>
  630. <autoTerminate>false</autoTerminate>
  631. <name>failure</name>
  632. </relationships>
  633. <relationships>
  634. <autoTerminate>false</autoTerminate>
  635. <name>success</name>
  636. </relationships>
  637. <style></style>
  638. <type>org.apache.nifi.processors.standard.ExecuteSQL</type>
  639. </processors>
  640. </contents>
  641. <name>MySQL Decimal</name>
  642. </processGroups>
  643. </snippet>
  644. <timestamp>06/13/2017 11:39:02 JST</timestamp>
  645. </template>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement