API tools faq
paste
Guest User

Untitled

a guest
Apr 13th, 2018
141
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 20.98 KB | None | 0 0
raw download clone embed print report
  1. <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
  2. <template encoding-version="1.2">
  3. <description></description>
  4. <groupId>0e837b11-51c1-31aa-0e85-e47b613cb446</groupId>
  5. <name>CSV to Dynamic Table</name>
  6. <snippet>
  7. <controllerServices>
  8. <id>4b085524-a4f2-3e9c-0000-000000000000</id>
  9. <parentGroupId>da8f6d4f-d71c-3c9e-0000-000000000000</parentGroupId>
  10. <bundle>
  11. <artifact>nifi-dbcp-service-nar</artifact>
  12. <group>org.apache.nifi</group>
  13. <version>1.5.0</version>
  14. </bundle>
  15. <comments></comments>
  16. <descriptors>
  17. <entry>
  18. <key>Database Connection URL</key>
  19. <value>
  20. <name>Database Connection URL</name>
  21. </value>
  22. </entry>
  23. <entry>
  24. <key>Database Driver Class Name</key>
  25. <value>
  26. <name>Database Driver Class Name</name>
  27. </value>
  28. </entry>
  29. <entry>
  30. <key>database-driver-locations</key>
  31. <value>
  32. <name>database-driver-locations</name>
  33. </value>
  34. </entry>
  35. <entry>
  36. <key>Database User</key>
  37. <value>
  38. <name>Database User</name>
  39. </value>
  40. </entry>
  41. <entry>
  42. <key>Password</key>
  43. <value>
  44. <name>Password</name>
  45. </value>
  46. </entry>
  47. <entry>
  48. <key>Max Wait Time</key>
  49. <value>
  50. <name>Max Wait Time</name>
  51. </value>
  52. </entry>
  53. <entry>
  54. <key>Max Total Connections</key>
  55. <value>
  56. <name>Max Total Connections</name>
  57. </value>
  58. </entry>
  59. <entry>
  60. <key>Validation-query</key>
  61. <value>
  62. <name>Validation-query</name>
  63. </value>
  64. </entry>
  65. </descriptors>
  66. <name>DBCPConnectionPool</name>
  67. <persistsState>false</persistsState>
  68. <properties>
  69. <entry>
  70. <key>Database Connection URL</key>
  71. <value>jdbc:postgresql://localhost:5432/postgres</value>
  72. </entry>
  73. <entry>
  74. <key>Database Driver Class Name</key>
  75. <value>org.postgresql.Driver</value>
  76. </entry>
  77. <entry>
  78. <key>database-driver-locations</key>
  79. <value>/Users/venkataseshasainagarajubolisetti/Desktop/GE/softwares/jars/postgresql-42.2.2.jar</value>
  80. </entry>
  81. <entry>
  82. <key>Database User</key>
  83. <value>venkatabolisetti</value>
  84. </entry>
  85. <entry>
  86. <key>Password</key>
  87. </entry>
  88. <entry>
  89. <key>Max Wait Time</key>
  90. <value>500 millis</value>
  91. </entry>
  92. <entry>
  93. <key>Max Total Connections</key>
  94. <value>8</value>
  95. </entry>
  96. <entry>
  97. <key>Validation-query</key>
  98. </entry>
  99. </properties>
  100. <state>ENABLED</state>
  101. <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
  102. </controllerServices>
  103. <processors>
  104. <id>1372a1e0-461d-3abb-0000-000000000000</id>
  105. <parentGroupId>da8f6d4f-d71c-3c9e-0000-000000000000</parentGroupId>
  106. <position>
  107. <x>0.0</x>
  108. <y>466.09250052955383</y>
  109. </position>
  110. <bundle>
  111. <artifact>nifi-standard-nar</artifact>
  112. <group>org.apache.nifi</group>
  113. <version>1.5.0</version>
  114. </bundle>
  115. <config>
  116. <bulletinLevel>WARN</bulletinLevel>
  117. <comments></comments>
  118. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  119. <descriptors>
  120. <entry>
  121. <key>JDBC Connection Pool</key>
  122. <value>
  123. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  124. <name>JDBC Connection Pool</name>
  125. </value>
  126. </entry>
  127. <entry>
  128. <key>putsql-sql-statement</key>
  129. <value>
  130. <name>putsql-sql-statement</name>
  131. </value>
  132. </entry>
  133. <entry>
  134. <key>Support Fragmented Transactions</key>
  135. <value>
  136. <name>Support Fragmented Transactions</name>
  137. </value>
  138. </entry>
  139. <entry>
  140. <key>Transaction Timeout</key>
  141. <value>
  142. <name>Transaction Timeout</name>
  143. </value>
  144. </entry>
  145. <entry>
  146. <key>Batch Size</key>
  147. <value>
  148. <name>Batch Size</name>
  149. </value>
  150. </entry>
  151. <entry>
  152. <key>Obtain Generated Keys</key>
  153. <value>
  154. <name>Obtain Generated Keys</name>
  155. </value>
  156. </entry>
  157. <entry>
  158. <key>rollback-on-failure</key>
  159. <value>
  160. <name>rollback-on-failure</name>
  161. </value>
  162. </entry>
  163. </descriptors>
  164. <executionNode>ALL</executionNode>
  165. <lossTolerant>false</lossTolerant>
  166. <penaltyDuration>30 sec</penaltyDuration>
  167. <properties>
  168. <entry>
  169. <key>JDBC Connection Pool</key>
  170. <value>4b085524-a4f2-3e9c-0000-000000000000</value>
  171. </entry>
  172. <entry>
  173. <key>putsql-sql-statement</key>
  174. <value>${ddlj}</value>
  175. </entry>
  176. <entry>
  177. <key>Support Fragmented Transactions</key>
  178. <value>true</value>
  179. </entry>
  180. <entry>
  181. <key>Transaction Timeout</key>
  182. </entry>
  183. <entry>
  184. <key>Batch Size</key>
  185. <value>100</value>
  186. </entry>
  187. <entry>
  188. <key>Obtain Generated Keys</key>
  189. <value>false</value>
  190. </entry>
  191. <entry>
  192. <key>rollback-on-failure</key>
  193. <value>false</value>
  194. </entry>
  195. </properties>
  196. <runDurationMillis>0</runDurationMillis>
  197. <schedulingPeriod>0 sec</schedulingPeriod>
  198. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  199. <yieldDuration>1 sec</yieldDuration>
  200. </config>
  201. <name>PutSQL</name>
  202. <relationships>
  203. <autoTerminate>true</autoTerminate>
  204. <name>failure</name>
  205. </relationships>
  206. <relationships>
  207. <autoTerminate>true</autoTerminate>
  208. <name>retry</name>
  209. </relationships>
  210. <relationships>
  211. <autoTerminate>false</autoTerminate>
  212. <name>success</name>
  213. </relationships>
  214. <state>RUNNING</state>
  215. <style/>
  216. <type>org.apache.nifi.processors.standard.PutSQL</type>
  217. </processors>
  218. <processors>
  219. <id>40cafaf4-79a9-3f09-0000-000000000000</id>
  220. <parentGroupId>da8f6d4f-d71c-3c9e-0000-000000000000</parentGroupId>
  221. <position>
  222. <x>0.0</x>
  223. <y>218.43659973144543</y>
  224. </position>
  225. <bundle>
  226. <artifact>nifi-update-attribute-nar</artifact>
  227. <group>org.apache.nifi</group>
  228. <version>1.5.0</version>
  229. </bundle>
  230. <config>
  231. <bulletinLevel>WARN</bulletinLevel>
  232. <comments></comments>
  233. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  234. <descriptors>
  235. <entry>
  236. <key>Delete Attributes Expression</key>
  237. <value>
  238. <name>Delete Attributes Expression</name>
  239. </value>
  240. </entry>
  241. <entry>
  242. <key>Store State</key>
  243. <value>
  244. <name>Store State</name>
  245. </value>
  246. </entry>
  247. <entry>
  248. <key>Stateful Variables Initial Value</key>
  249. <value>
  250. <name>Stateful Variables Initial Value</name>
  251. </value>
  252. </entry>
  253. <entry>
  254. <key>table_name</key>
  255. <value>
  256. <name>table_name</name>
  257. </value>
  258. </entry>
  259. </descriptors>
  260. <executionNode>ALL</executionNode>
  261. <lossTolerant>false</lossTolerant>
  262. <penaltyDuration>30 sec</penaltyDuration>
  263. <properties>
  264. <entry>
  265. <key>Delete Attributes Expression</key>
  266. </entry>
  267. <entry>
  268. <key>Store State</key>
  269. <value>Do not store state</value>
  270. </entry>
  271. <entry>
  272. <key>Stateful Variables Initial Value</key>
  273. </entry>
  274. <entry>
  275. <key>table_name</key>
  276. <value>${filename}</value>
  277. </entry>
  278. </properties>
  279. <runDurationMillis>0</runDurationMillis>
  280. <schedulingPeriod>0 sec</schedulingPeriod>
  281. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  282. <yieldDuration>1 sec</yieldDuration>
  283. </config>
  284. <name>UpdateAttribute</name>
  285. <relationships>
  286. <autoTerminate>false</autoTerminate>
  287. <name>success</name>
  288. </relationships>
  289. <state>RUNNING</state>
  290. <style/>
  291. <type>org.apache.nifi.processors.attributes.UpdateAttribute</type>
  292. </processors>
  293. <processors>
  294. <id>5be35722-846d-3340-0000-000000000000</id>
  295. <parentGroupId>da8f6d4f-d71c-3c9e-0000-000000000000</parentGroupId>
  296. <position>
  297. <x>0.0</x>
  298. <y>0.0</y>
  299. </position>
  300. <bundle>
  301. <artifact>nifi-kite-nar</artifact>
  302. <group>org.apache.nifi</group>
  303. <version>1.5.0</version>
  304. </bundle>
  305. <config>
  306. <bulletinLevel>WARN</bulletinLevel>
  307. <comments></comments>
  308. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  309. <descriptors>
  310. <entry>
  311. <key>Schema Output Destination</key>
  312. <value>
  313. <name>Schema Output Destination</name>
  314. </value>
  315. </entry>
  316. <entry>
  317. <key>Input Content Type</key>
  318. <value>
  319. <name>Input Content Type</name>
  320. </value>
  321. </entry>
  322. <entry>
  323. <key>CSV Header Definition</key>
  324. <value>
  325. <name>CSV Header Definition</name>
  326. </value>
  327. </entry>
  328. <entry>
  329. <key>Get CSV Header Definition From Data</key>
  330. <value>
  331. <name>Get CSV Header Definition From Data</name>
  332. </value>
  333. </entry>
  334. <entry>
  335. <key>CSV Header Line Skip Count</key>
  336. <value>
  337. <name>CSV Header Line Skip Count</name>
  338. </value>
  339. </entry>
  340. <entry>
  341. <key>CSV delimiter</key>
  342. <value>
  343. <name>CSV delimiter</name>
  344. </value>
  345. </entry>
  346. <entry>
  347. <key>CSV Escape String</key>
  348. <value>
  349. <name>CSV Escape String</name>
  350. </value>
  351. </entry>
  352. <entry>
  353. <key>CSV Quote String</key>
  354. <value>
  355. <name>CSV Quote String</name>
  356. </value>
  357. </entry>
  358. <entry>
  359. <key>Pretty Avro Output</key>
  360. <value>
  361. <name>Pretty Avro Output</name>
  362. </value>
  363. </entry>
  364. <entry>
  365. <key>Avro Record Name</key>
  366. <value>
  367. <name>Avro Record Name</name>
  368. </value>
  369. </entry>
  370. <entry>
  371. <key>Number Of Records To Analyze</key>
  372. <value>
  373. <name>Number Of Records To Analyze</name>
  374. </value>
  375. </entry>
  376. <entry>
  377. <key>Charset</key>
  378. <value>
  379. <name>Charset</name>
  380. </value>
  381. </entry>
  382. </descriptors>
  383. <executionNode>ALL</executionNode>
  384. <lossTolerant>false</lossTolerant>
  385. <penaltyDuration>30 sec</penaltyDuration>
  386. <properties>
  387. <entry>
  388. <key>Schema Output Destination</key>
  389. <value>flowfile-attribute</value>
  390. </entry>
  391. <entry>
  392. <key>Input Content Type</key>
  393. <value>csv</value>
  394. </entry>
  395. <entry>
  396. <key>CSV Header Definition</key>
  397. </entry>
  398. <entry>
  399. <key>Get CSV Header Definition From Data</key>
  400. <value>true</value>
  401. </entry>
  402. <entry>
  403. <key>CSV Header Line Skip Count</key>
  404. <value>0</value>
  405. </entry>
  406. <entry>
  407. <key>CSV delimiter</key>
  408. <value>,</value>
  409. </entry>
  410. <entry>
  411. <key>CSV Escape String</key>
  412. <value>\</value>
  413. </entry>
  414. <entry>
  415. <key>CSV Quote String</key>
  416. <value>'</value>
  417. </entry>
  418. <entry>
  419. <key>Pretty Avro Output</key>
  420. <value>true</value>
  421. </entry>
  422. <entry>
  423. <key>Avro Record Name</key>
  424. <value>myavro</value>
  425. </entry>
  426. <entry>
  427. <key>Number Of Records To Analyze</key>
  428. <value>10</value>
  429. </entry>
  430. <entry>
  431. <key>Charset</key>
  432. <value>UTF-8</value>
  433. </entry>
  434. </properties>
  435. <runDurationMillis>0</runDurationMillis>
  436. <schedulingPeriod>0 sec</schedulingPeriod>
  437. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  438. <yieldDuration>1 sec</yieldDuration>
  439. </config>
  440. <name>InferAvroSchema</name>
  441. <relationships>
  442. <autoTerminate>true</autoTerminate>
  443. <name>failure</name>
  444. </relationships>
  445. <relationships>
  446. <autoTerminate>true</autoTerminate>
  447. <name>original</name>
  448. </relationships>
  449. <relationships>
  450. <autoTerminate>false</autoTerminate>
  451. <name>success</name>
  452. </relationships>
  453. <relationships>
  454. <autoTerminate>true</autoTerminate>
  455. <name>unsupported content</name>
  456. </relationships>
  457. <state>RUNNING</state>
  458. <style/>
  459. <type>org.apache.nifi.processors.kite.InferAvroSchema</type>
  460. </processors>
  461. <processors>
  462. <id>71c9f90d-f83b-367f-0000-000000000000</id>
  463. <parentGroupId>da8f6d4f-d71c-3c9e-0000-000000000000</parentGroupId>
  464. <position>
  465. <x>0.0</x>
  466. <y>713.9508361816407</y>
  467. </position>
  468. <bundle>
  469. <artifact>nifi-update-attribute-nar</artifact>
  470. <group>org.apache.nifi</group>
  471. <version>1.5.0</version>
  472. </bundle>
  473. <config>
  474. <bulletinLevel>WARN</bulletinLevel>
  475. <comments></comments>
  476. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  477. <descriptors>
  478. <entry>
  479. <key>Delete Attributes Expression</key>
  480. <value>
  481. <name>Delete Attributes Expression</name>
  482. </value>
  483. </entry>
  484. <entry>
  485. <key>Store State</key>
  486. <value>
  487. <name>Store State</name>
  488. </value>
  489. </entry>
  490. <entry>
  491. <key>Stateful Variables Initial Value</key>
  492. <value>
  493. <name>Stateful Variables Initial Value</name>
  494. </value>
  495. </entry>
  496. <entry>
  497. <key>ddlj</key>
  498. <value>
  499. <name>ddlj</name>
  500. </value>
  501. </entry>
  502. </descriptors>
  503. <executionNode>ALL</executionNode>
  504. <lossTolerant>false</lossTolerant>
  505. <penaltyDuration>30 sec</penaltyDuration>
  506. <properties>
  507. <entry>
  508. <key>Delete Attributes Expression</key>
  509. </entry>
  510. <entry>
  511. <key>Store State</key>
  512. <value>Do not store state</value>
  513. </entry>
  514. <entry>
  515. <key>Stateful Variables Initial Value</key>
  516. </entry>
  517. <entry>
  518. <key>ddlj</key>
  519. <value>${finalddl:replace('tempTable', ${table_name})}</value>
  520. </entry>
  521. </properties>
  522. <runDurationMillis>0</runDurationMillis>
  523. <schedulingPeriod>0 sec</schedulingPeriod>
  524. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  525. <yieldDuration>1 sec</yieldDuration>
  526. </config>
  527. <name>UpdateAttribute</name>
  528. <relationships>
  529. <autoTerminate>false</autoTerminate>
  530. <name>success</name>
  531. </relationships>
  532. <state>RUNNING</state>
  533. <style/>
  534. <type>org.apache.nifi.processors.attributes.UpdateAttribute</type>
  535. </processors>
  536. </snippet>
  537. <timestamp>04/05/2018 21:02:21 EDT</timestamp>
  538. </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!