API tools faq
paste
Guest User

Untitled

a guest
Aug 22nd, 2018
94
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 36.54 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>This template gives an example of using a ScriptedLookupService to provide sequence numbers from a database.</description>
  4. <groupId>5d7e55f8-0165-1000-1170-d42741815ddb</groupId>
  5. <name>SequenceLookupExample</name>
  6. <snippet>
  7. <connections>
  8. <id>0cf6aae2-8e5a-361f-0000-000000000000</id>
  9. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  10. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  11. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  12. <destination>
  13. <groupId>cedd92a0-903e-3f68-0000-000000000000</groupId>
  14. <id>18d932d9-9435-3d73-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>cedd92a0-903e-3f68-0000-000000000000</groupId>
  23. <id>226a0b7a-4223-3391-0000-000000000000</id>
  24. <type>PROCESSOR</type>
  25. </source>
  26. <zIndex>0</zIndex>
  27. </connections>
  28. <connections>
  29. <id>2323e874-4974-31d6-0000-000000000000</id>
  30. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  31. <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
  32. <backPressureObjectThreshold>10000</backPressureObjectThreshold>
  33. <destination>
  34. <groupId>cedd92a0-903e-3f68-0000-000000000000</groupId>
  35. <id>d9c33af1-d7f3-34f3-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>cedd92a0-903e-3f68-0000-000000000000</groupId>
  44. <id>18d932d9-9435-3d73-0000-000000000000</id>
  45. <type>PROCESSOR</type>
  46. </source>
  47. <zIndex>0</zIndex>
  48. </connections>
  49. <controllerServices>
  50. <id>32afb585-f4c2-39fe-0000-000000000000</id>
  51. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  52. <bundle>
  53. <artifact>nifi-scripting-nar</artifact>
  54. <group>org.apache.nifi</group>
  55. <version>1.8.0-SNAPSHOT</version>
  56. </bundle>
  57. <comments></comments>
  58. <descriptors>
  59. <entry>
  60. <key>Script Engine</key>
  61. <value>
  62. <name>Script Engine</name>
  63. </value>
  64. </entry>
  65. <entry>
  66. <key>Script File</key>
  67. <value>
  68. <name>Script File</name>
  69. </value>
  70. </entry>
  71. <entry>
  72. <key>Script Body</key>
  73. <value>
  74. <name>Script Body</name>
  75. </value>
  76. </entry>
  77. <entry>
  78. <key>Module Directory</key>
  79. <value>
  80. <name>Module Directory</name>
  81. </value>
  82. </entry>
  83. <entry>
  84. <key>Database Connection Pooling Service</key>
  85. <value>
  86. <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService>
  87. <name>Database Connection Pooling Service</name>
  88. </value>
  89. </entry>
  90. </descriptors>
  91. <name>ScriptedLookupService</name>
  92. <persistsState>false</persistsState>
  93. <properties>
  94. <entry>
  95. <key>Script Engine</key>
  96. <value>Groovy</value>
  97. </entry>
  98. <entry>
  99. <key>Script File</key>
  100. </entry>
  101. <entry>
  102. <key>Script Body</key>
  103. <value>import org.apache.nifi.controller.ControllerServiceInitializationContext
  104. import org.apache.nifi.reporting.InitializationException
  105. import org.apache.nifi.dbcp.DBCPService
  106. import java.sql.*
  107.  
  108. class SequenceLookupService implements LookupService<String> {
  109.  
  110. final String ID = UUID.randomUUID().toString()
  111.  
  112. public static final PropertyDescriptor DBCP_SERVICE = new PropertyDescriptor.Builder()
  113. .name("Database Connection Pooling Service")
  114. .description("The Controller Service that is used to obtain connection to database")
  115. .required(true)
  116. .identifiesControllerService(DBCPService)
  117. .build()
  118.  
  119. Connection conn = null
  120. Statement stmt = null
  121. ComponentLog log = null
  122.  
  123. @Override
  124. Optional<String> lookup(Map<String, String> coordinates) {
  125. final String key = coordinates.keySet().first()
  126. ResultSet rs = stmt?.executeQuery("select nextval('${key}')".toString())
  127. return rs.next() ? Optional.ofNullable(rs.getLong(1)) : null
  128. }
  129.  
  130. Set<String> getRequiredKeys() {
  131. return java.util.Collections.emptySet();
  132. }
  133.  
  134. @Override
  135. Class<?> getValueType() {
  136. return String
  137. }
  138.  
  139. @Override
  140. void initialize(ControllerServiceInitializationContext context) throws InitializationException {
  141. }
  142.  
  143. @Override
  144. Collection<ValidationResult> validate(ValidationContext context) {
  145. null
  146. }
  147.  
  148. @Override
  149. PropertyDescriptor getPropertyDescriptor(String name) {
  150. name.equals(DBCP_SERVICE.name) ? DBCP_SERVICE : null
  151. }
  152.  
  153. @Override
  154. void onPropertyModified(PropertyDescriptor descriptor, String oldValue, String newValue) {
  155. }
  156.  
  157. @Override
  158. List<PropertyDescriptor> getPropertyDescriptors() {
  159. [DBCP_SERVICE] as List;
  160. }
  161.  
  162. @Override
  163. String getIdentifier() {
  164. ID
  165. }
  166.  
  167. def onEnabled(context) {
  168. def db = context.getProperty(DBCP_SERVICE).asControllerService(DBCPService)
  169. conn = db.connection
  170. stmt = conn.createStatement()
  171. }
  172.  
  173. def onDisabled() {
  174. conn?.close()
  175. }
  176.  
  177. def setLogger(logger) {
  178. log = logger
  179. }
  180. }
  181.  
  182. lookupService = new SequenceLookupService()</value>
  183. </entry>
  184. <entry>
  185. <key>Module Directory</key>
  186. </entry>
  187. <entry>
  188. <key>Database Connection Pooling Service</key>
  189. <value>bc8e3471-418f-38ff-0000-000000000000</value>
  190. </entry>
  191. </properties>
  192. <state>ENABLED</state>
  193. <type>org.apache.nifi.lookup.script.ScriptedLookupService</type>
  194. </controllerServices>
  195. <controllerServices>
  196. <id>508cb3a3-b4db-3605-0000-000000000000</id>
  197. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  198. <bundle>
  199. <artifact>nifi-record-serialization-services-nar</artifact>
  200. <group>org.apache.nifi</group>
  201. <version>1.8.0-SNAPSHOT</version>
  202. </bundle>
  203. <comments></comments>
  204. <descriptors>
  205. <entry>
  206. <key>schema-access-strategy</key>
  207. <value>
  208. <name>schema-access-strategy</name>
  209. </value>
  210. </entry>
  211. <entry>
  212. <key>schema-registry</key>
  213. <value>
  214. <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
  215. <name>schema-registry</name>
  216. </value>
  217. </entry>
  218. <entry>
  219. <key>schema-name</key>
  220. <value>
  221. <name>schema-name</name>
  222. </value>
  223. </entry>
  224. <entry>
  225. <key>schema-version</key>
  226. <value>
  227. <name>schema-version</name>
  228. </value>
  229. </entry>
  230. <entry>
  231. <key>schema-branch</key>
  232. <value>
  233. <name>schema-branch</name>
  234. </value>
  235. </entry>
  236. <entry>
  237. <key>schema-text</key>
  238. <value>
  239. <name>schema-text</name>
  240. </value>
  241. </entry>
  242. <entry>
  243. <key>csv-reader-csv-parser</key>
  244. <value>
  245. <name>csv-reader-csv-parser</name>
  246. </value>
  247. </entry>
  248. <entry>
  249. <key>Date Format</key>
  250. <value>
  251. <name>Date Format</name>
  252. </value>
  253. </entry>
  254. <entry>
  255. <key>Time Format</key>
  256. <value>
  257. <name>Time Format</name>
  258. </value>
  259. </entry>
  260. <entry>
  261. <key>Timestamp Format</key>
  262. <value>
  263. <name>Timestamp Format</name>
  264. </value>
  265. </entry>
  266. <entry>
  267. <key>CSV Format</key>
  268. <value>
  269. <name>CSV Format</name>
  270. </value>
  271. </entry>
  272. <entry>
  273. <key>Value Separator</key>
  274. <value>
  275. <name>Value Separator</name>
  276. </value>
  277. </entry>
  278. <entry>
  279. <key>Skip Header Line</key>
  280. <value>
  281. <name>Skip Header Line</name>
  282. </value>
  283. </entry>
  284. <entry>
  285. <key>ignore-csv-header</key>
  286. <value>
  287. <name>ignore-csv-header</name>
  288. </value>
  289. </entry>
  290. <entry>
  291. <key>Quote Character</key>
  292. <value>
  293. <name>Quote Character</name>
  294. </value>
  295. </entry>
  296. <entry>
  297. <key>Escape Character</key>
  298. <value>
  299. <name>Escape Character</name>
  300. </value>
  301. </entry>
  302. <entry>
  303. <key>Comment Marker</key>
  304. <value>
  305. <name>Comment Marker</name>
  306. </value>
  307. </entry>
  308. <entry>
  309. <key>Null String</key>
  310. <value>
  311. <name>Null String</name>
  312. </value>
  313. </entry>
  314. <entry>
  315. <key>Trim Fields</key>
  316. <value>
  317. <name>Trim Fields</name>
  318. </value>
  319. </entry>
  320. <entry>
  321. <key>csvutils-character-set</key>
  322. <value>
  323. <name>csvutils-character-set</name>
  324. </value>
  325. </entry>
  326. </descriptors>
  327. <name>CSVReader</name>
  328. <persistsState>false</persistsState>
  329. <properties>
  330. <entry>
  331. <key>schema-access-strategy</key>
  332. <value>schema-text-property</value>
  333. </entry>
  334. <entry>
  335. <key>schema-registry</key>
  336. </entry>
  337. <entry>
  338. <key>schema-name</key>
  339. <value>${schema.name}</value>
  340. </entry>
  341. <entry>
  342. <key>schema-version</key>
  343. </entry>
  344. <entry>
  345. <key>schema-branch</key>
  346. </entry>
  347. <entry>
  348. <key>schema-text</key>
  349. <value>{ "type" : "record", "name" : "MyClass", "namespace" : "com.test.avro", "fields" : [
  350. { "name" : "studentName", "type" : "string" },
  351. { "name" : "Age", "type" : "string" },
  352. { "name" : "address_city", "type" : "string" },
  353. { "name" : "address1", "type" : "string" },
  354. { "name" : "zipcode", "type" : "string" },
  355. { "name" : "id", "type": ["null", "string"]}
  356. ]}</value>
  357. </entry>
  358. <entry>
  359. <key>csv-reader-csv-parser</key>
  360. <value>jackson-csv</value>
  361. </entry>
  362. <entry>
  363. <key>Date Format</key>
  364. </entry>
  365. <entry>
  366. <key>Time Format</key>
  367. </entry>
  368. <entry>
  369. <key>Timestamp Format</key>
  370. </entry>
  371. <entry>
  372. <key>CSV Format</key>
  373. <value>custom</value>
  374. </entry>
  375. <entry>
  376. <key>Value Separator</key>
  377. <value>,</value>
  378. </entry>
  379. <entry>
  380. <key>Skip Header Line</key>
  381. <value>false</value>
  382. </entry>
  383. <entry>
  384. <key>ignore-csv-header</key>
  385. <value>false</value>
  386. </entry>
  387. <entry>
  388. <key>Quote Character</key>
  389. <value>"</value>
  390. </entry>
  391. <entry>
  392. <key>Escape Character</key>
  393. <value>\</value>
  394. </entry>
  395. <entry>
  396. <key>Comment Marker</key>
  397. </entry>
  398. <entry>
  399. <key>Null String</key>
  400. </entry>
  401. <entry>
  402. <key>Trim Fields</key>
  403. <value>true</value>
  404. </entry>
  405. <entry>
  406. <key>csvutils-character-set</key>
  407. <value>UTF-8</value>
  408. </entry>
  409. </properties>
  410. <state>ENABLED</state>
  411. <type>org.apache.nifi.csv.CSVReader</type>
  412. </controllerServices>
  413. <controllerServices>
  414. <id>9829c5cc-dd04-3c8c-0000-000000000000</id>
  415. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  416. <bundle>
  417. <artifact>nifi-record-serialization-services-nar</artifact>
  418. <group>org.apache.nifi</group>
  419. <version>1.8.0-SNAPSHOT</version>
  420. </bundle>
  421. <comments></comments>
  422. <descriptors>
  423. <entry>
  424. <key>Schema Write Strategy</key>
  425. <value>
  426. <name>Schema Write Strategy</name>
  427. </value>
  428. </entry>
  429. <entry>
  430. <key>schema-access-strategy</key>
  431. <value>
  432. <name>schema-access-strategy</name>
  433. </value>
  434. </entry>
  435. <entry>
  436. <key>schema-registry</key>
  437. <value>
  438. <identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService>
  439. <name>schema-registry</name>
  440. </value>
  441. </entry>
  442. <entry>
  443. <key>schema-name</key>
  444. <value>
  445. <name>schema-name</name>
  446. </value>
  447. </entry>
  448. <entry>
  449. <key>schema-version</key>
  450. <value>
  451. <name>schema-version</name>
  452. </value>
  453. </entry>
  454. <entry>
  455. <key>schema-branch</key>
  456. <value>
  457. <name>schema-branch</name>
  458. </value>
  459. </entry>
  460. <entry>
  461. <key>schema-text</key>
  462. <value>
  463. <name>schema-text</name>
  464. </value>
  465. </entry>
  466. <entry>
  467. <key>Date Format</key>
  468. <value>
  469. <name>Date Format</name>
  470. </value>
  471. </entry>
  472. <entry>
  473. <key>Time Format</key>
  474. <value>
  475. <name>Time Format</name>
  476. </value>
  477. </entry>
  478. <entry>
  479. <key>Timestamp Format</key>
  480. <value>
  481. <name>Timestamp Format</name>
  482. </value>
  483. </entry>
  484. <entry>
  485. <key>Pretty Print JSON</key>
  486. <value>
  487. <name>Pretty Print JSON</name>
  488. </value>
  489. </entry>
  490. <entry>
  491. <key>suppress-nulls</key>
  492. <value>
  493. <name>suppress-nulls</name>
  494. </value>
  495. </entry>
  496. <entry>
  497. <key>output-grouping</key>
  498. <value>
  499. <name>output-grouping</name>
  500. </value>
  501. </entry>
  502. </descriptors>
  503. <name>JsonRecordSetWriter</name>
  504. <persistsState>false</persistsState>
  505. <properties>
  506. <entry>
  507. <key>Schema Write Strategy</key>
  508. <value>full-schema-attribute</value>
  509. </entry>
  510. <entry>
  511. <key>schema-access-strategy</key>
  512. <value>inherit-record-schema</value>
  513. </entry>
  514. <entry>
  515. <key>schema-registry</key>
  516. </entry>
  517. <entry>
  518. <key>schema-name</key>
  519. <value>${schema.name}</value>
  520. </entry>
  521. <entry>
  522. <key>schema-version</key>
  523. </entry>
  524. <entry>
  525. <key>schema-branch</key>
  526. </entry>
  527. <entry>
  528. <key>schema-text</key>
  529. <value>{ "type" : "record", "name" : "MyClass", "namespace" : "com.test.avro", "fields" : [
  530. { "name" : "studentName", "type" : "string" },
  531. { "name" : "Age", "type" : "string" },
  532. { "name" : "address_city", "type" : "string" },
  533. { "name" : "address1", "type" : "string" },
  534. { "name" : "zipcode", "type" : "string" },
  535. { "name" : "id", "type": ["null", "string"]}
  536. ]}</value>
  537. </entry>
  538. <entry>
  539. <key>Date Format</key>
  540. </entry>
  541. <entry>
  542. <key>Time Format</key>
  543. </entry>
  544. <entry>
  545. <key>Timestamp Format</key>
  546. </entry>
  547. <entry>
  548. <key>Pretty Print JSON</key>
  549. <value>false</value>
  550. </entry>
  551. <entry>
  552. <key>suppress-nulls</key>
  553. <value>never-suppress</value>
  554. </entry>
  555. <entry>
  556. <key>output-grouping</key>
  557. <value>output-array</value>
  558. </entry>
  559. </properties>
  560. <state>ENABLED</state>
  561. <type>org.apache.nifi.json.JsonRecordSetWriter</type>
  562. </controllerServices>
  563. <controllerServices>
  564. <id>bc8e3471-418f-38ff-0000-000000000000</id>
  565. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  566. <bundle>
  567. <artifact>nifi-dbcp-service-nar</artifact>
  568. <group>org.apache.nifi</group>
  569. <version>1.8.0-SNAPSHOT</version>
  570. </bundle>
  571. <comments></comments>
  572. <descriptors>
  573. <entry>
  574. <key>Database Connection URL</key>
  575. <value>
  576. <name>Database Connection URL</name>
  577. </value>
  578. </entry>
  579. <entry>
  580. <key>Database Driver Class Name</key>
  581. <value>
  582. <name>Database Driver Class Name</name>
  583. </value>
  584. </entry>
  585. <entry>
  586. <key>database-driver-locations</key>
  587. <value>
  588. <name>database-driver-locations</name>
  589. </value>
  590. </entry>
  591. <entry>
  592. <key>Database User</key>
  593. <value>
  594. <name>Database User</name>
  595. </value>
  596. </entry>
  597. <entry>
  598. <key>Password</key>
  599. <value>
  600. <name>Password</name>
  601. </value>
  602. </entry>
  603. <entry>
  604. <key>Max Wait Time</key>
  605. <value>
  606. <name>Max Wait Time</name>
  607. </value>
  608. </entry>
  609. <entry>
  610. <key>Max Total Connections</key>
  611. <value>
  612. <name>Max Total Connections</name>
  613. </value>
  614. </entry>
  615. <entry>
  616. <key>Validation-query</key>
  617. <value>
  618. <name>Validation-query</name>
  619. </value>
  620. </entry>
  621. </descriptors>
  622. <name>PostgresConnectionPool</name>
  623. <persistsState>false</persistsState>
  624. <properties>
  625. <entry>
  626. <key>Database Connection URL</key>
  627. <value>jdbc:postgresql://localhost:5432/postgres</value>
  628. </entry>
  629. <entry>
  630. <key>Database Driver Class Name</key>
  631. <value>org.postgresql.Driver</value>
  632. </entry>
  633. <entry>
  634. <key>database-driver-locations</key>
  635. <value>/Users/mburgess/jdbc_drivers/postgresql-9.3-1102-jdbc4.jar</value>
  636. </entry>
  637. <entry>
  638. <key>Database User</key>
  639. <value>postgres</value>
  640. </entry>
  641. <entry>
  642. <key>Password</key>
  643. </entry>
  644. <entry>
  645. <key>Max Wait Time</key>
  646. <value>500 millis</value>
  647. </entry>
  648. <entry>
  649. <key>Max Total Connections</key>
  650. <value>8</value>
  651. </entry>
  652. <entry>
  653. <key>Validation-query</key>
  654. </entry>
  655. </properties>
  656. <state>ENABLED</state>
  657. <type>org.apache.nifi.dbcp.DBCPConnectionPool</type>
  658. </controllerServices>
  659. <processors>
  660. <id>18d932d9-9435-3d73-0000-000000000000</id>
  661. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  662. <position>
  663. <x>4.515228140595582</x>
  664. <y>212.55852447762416</y>
  665. </position>
  666. <bundle>
  667. <artifact>nifi-standard-nar</artifact>
  668. <group>org.apache.nifi</group>
  669. <version>1.8.0-SNAPSHOT</version>
  670. </bundle>
  671. <config>
  672. <bulletinLevel>WARN</bulletinLevel>
  673. <comments></comments>
  674. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  675. <descriptors>
  676. <entry>
  677. <key>record-reader</key>
  678. <value>
  679. <identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService>
  680. <name>record-reader</name>
  681. </value>
  682. </entry>
  683. <entry>
  684. <key>record-writer</key>
  685. <value>
  686. <identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService>
  687. <name>record-writer</name>
  688. </value>
  689. </entry>
  690. <entry>
  691. <key>lookup-service</key>
  692. <value>
  693. <identifiesControllerService>org.apache.nifi.lookup.LookupService</identifiesControllerService>
  694. <name>lookup-service</name>
  695. </value>
  696. </entry>
  697. <entry>
  698. <key>result-record-path</key>
  699. <value>
  700. <name>result-record-path</name>
  701. </value>
  702. </entry>
  703. <entry>
  704. <key>routing-strategy</key>
  705. <value>
  706. <name>routing-strategy</name>
  707. </value>
  708. </entry>
  709. <entry>
  710. <key>result-contents</key>
  711. <value>
  712. <name>result-contents</name>
  713. </value>
  714. </entry>
  715. <entry>
  716. <key>id_seq</key>
  717. <value>
  718. <name>id_seq</name>
  719. </value>
  720. </entry>
  721. </descriptors>
  722. <executionNode>ALL</executionNode>
  723. <lossTolerant>false</lossTolerant>
  724. <penaltyDuration>30 sec</penaltyDuration>
  725. <properties>
  726. <entry>
  727. <key>record-reader</key>
  728. <value>508cb3a3-b4db-3605-0000-000000000000</value>
  729. </entry>
  730. <entry>
  731. <key>record-writer</key>
  732. <value>9829c5cc-dd04-3c8c-0000-000000000000</value>
  733. </entry>
  734. <entry>
  735. <key>lookup-service</key>
  736. <value>32afb585-f4c2-39fe-0000-000000000000</value>
  737. </entry>
  738. <entry>
  739. <key>result-record-path</key>
  740. <value>/id</value>
  741. </entry>
  742. <entry>
  743. <key>routing-strategy</key>
  744. <value>route-to-success</value>
  745. </entry>
  746. <entry>
  747. <key>result-contents</key>
  748. <value>record-fields</value>
  749. </entry>
  750. <entry>
  751. <key>id_seq</key>
  752. <value>/Age</value>
  753. </entry>
  754. </properties>
  755. <runDurationMillis>0</runDurationMillis>
  756. <schedulingPeriod>0 sec</schedulingPeriod>
  757. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  758. <yieldDuration>1 sec</yieldDuration>
  759. </config>
  760. <executionNodeRestricted>false</executionNodeRestricted>
  761. <name>LookupRecord</name>
  762. <relationships>
  763. <autoTerminate>true</autoTerminate>
  764. <name>failure</name>
  765. </relationships>
  766. <relationships>
  767. <autoTerminate>false</autoTerminate>
  768. <name>success</name>
  769. </relationships>
  770. <state>STOPPED</state>
  771. <style/>
  772. <type>org.apache.nifi.processors.standard.LookupRecord</type>
  773. </processors>
  774. <processors>
  775. <id>226a0b7a-4223-3391-0000-000000000000</id>
  776. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  777. <position>
  778. <x>0.0</x>
  779. <y>0.0</y>
  780. </position>
  781. <bundle>
  782. <artifact>nifi-standard-nar</artifact>
  783. <group>org.apache.nifi</group>
  784. <version>1.8.0-SNAPSHOT</version>
  785. </bundle>
  786. <config>
  787. <bulletinLevel>WARN</bulletinLevel>
  788. <comments></comments>
  789. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  790. <descriptors>
  791. <entry>
  792. <key>File Size</key>
  793. <value>
  794. <name>File Size</name>
  795. </value>
  796. </entry>
  797. <entry>
  798. <key>Batch Size</key>
  799. <value>
  800. <name>Batch Size</name>
  801. </value>
  802. </entry>
  803. <entry>
  804. <key>Data Format</key>
  805. <value>
  806. <name>Data Format</name>
  807. </value>
  808. </entry>
  809. <entry>
  810. <key>Unique FlowFiles</key>
  811. <value>
  812. <name>Unique FlowFiles</name>
  813. </value>
  814. </entry>
  815. <entry>
  816. <key>generate-ff-custom-text</key>
  817. <value>
  818. <name>generate-ff-custom-text</name>
  819. </value>
  820. </entry>
  821. <entry>
  822. <key>character-set</key>
  823. <value>
  824. <name>character-set</name>
  825. </value>
  826. </entry>
  827. </descriptors>
  828. <executionNode>ALL</executionNode>
  829. <lossTolerant>false</lossTolerant>
  830. <penaltyDuration>30 sec</penaltyDuration>
  831. <properties>
  832. <entry>
  833. <key>File Size</key>
  834. <value>0B</value>
  835. </entry>
  836. <entry>
  837. <key>Batch Size</key>
  838. <value>1</value>
  839. </entry>
  840. <entry>
  841. <key>Data Format</key>
  842. <value>Text</value>
  843. </entry>
  844. <entry>
  845. <key>Unique FlowFiles</key>
  846. <value>false</value>
  847. </entry>
  848. <entry>
  849. <key>generate-ff-custom-text</key>
  850. <value>"Foo","12","newyork","North avenue","123213"
  851. "Foo1","12","newyork","North avenue","123213"
  852. "Foo2","12","newyork","North avenue","123213"</value>
  853. </entry>
  854. <entry>
  855. <key>character-set</key>
  856. <value>UTF-8</value>
  857. </entry>
  858. </properties>
  859. <runDurationMillis>0</runDurationMillis>
  860. <schedulingPeriod>60 sec</schedulingPeriod>
  861. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  862. <yieldDuration>1 sec</yieldDuration>
  863. </config>
  864. <executionNodeRestricted>false</executionNodeRestricted>
  865. <name>GenerateFlowFile</name>
  866. <relationships>
  867. <autoTerminate>false</autoTerminate>
  868. <name>success</name>
  869. </relationships>
  870. <state>STOPPED</state>
  871. <style/>
  872. <type>org.apache.nifi.processors.standard.GenerateFlowFile</type>
  873. </processors>
  874. <processors>
  875. <id>d9c33af1-d7f3-34f3-0000-000000000000</id>
  876. <parentGroupId>cedd92a0-903e-3f68-0000-000000000000</parentGroupId>
  877. <position>
  878. <x>13.0</x>
  879. <y>452.0</y>
  880. </position>
  881. <bundle>
  882. <artifact>nifi-standard-nar</artifact>
  883. <group>org.apache.nifi</group>
  884. <version>1.8.0-SNAPSHOT</version>
  885. </bundle>
  886. <config>
  887. <bulletinLevel>WARN</bulletinLevel>
  888. <comments></comments>
  889. <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
  890. <descriptors>
  891. <entry>
  892. <key>Log Level</key>
  893. <value>
  894. <name>Log Level</name>
  895. </value>
  896. </entry>
  897. <entry>
  898. <key>Log Payload</key>
  899. <value>
  900. <name>Log Payload</name>
  901. </value>
  902. </entry>
  903. <entry>
  904. <key>Attributes to Log</key>
  905. <value>
  906. <name>Attributes to Log</name>
  907. </value>
  908. </entry>
  909. <entry>
  910. <key>attributes-to-log-regex</key>
  911. <value>
  912. <name>attributes-to-log-regex</name>
  913. </value>
  914. </entry>
  915. <entry>
  916. <key>Attributes to Ignore</key>
  917. <value>
  918. <name>Attributes to Ignore</name>
  919. </value>
  920. </entry>
  921. <entry>
  922. <key>attributes-to-ignore-regex</key>
  923. <value>
  924. <name>attributes-to-ignore-regex</name>
  925. </value>
  926. </entry>
  927. <entry>
  928. <key>Log prefix</key>
  929. <value>
  930. <name>Log prefix</name>
  931. </value>
  932. </entry>
  933. <entry>
  934. <key>character-set</key>
  935. <value>
  936. <name>character-set</name>
  937. </value>
  938. </entry>
  939. </descriptors>
  940. <executionNode>ALL</executionNode>
  941. <lossTolerant>false</lossTolerant>
  942. <penaltyDuration>30 sec</penaltyDuration>
  943. <properties>
  944. <entry>
  945. <key>Log Level</key>
  946. <value>info</value>
  947. </entry>
  948. <entry>
  949. <key>Log Payload</key>
  950. <value>false</value>
  951. </entry>
  952. <entry>
  953. <key>Attributes to Log</key>
  954. </entry>
  955. <entry>
  956. <key>attributes-to-log-regex</key>
  957. <value>.*</value>
  958. </entry>
  959. <entry>
  960. <key>Attributes to Ignore</key>
  961. </entry>
  962. <entry>
  963. <key>attributes-to-ignore-regex</key>
  964. </entry>
  965. <entry>
  966. <key>Log prefix</key>
  967. </entry>
  968. <entry>
  969. <key>character-set</key>
  970. <value>UTF-8</value>
  971. </entry>
  972. </properties>
  973. <runDurationMillis>0</runDurationMillis>
  974. <schedulingPeriod>0 sec</schedulingPeriod>
  975. <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
  976. <yieldDuration>1 sec</yieldDuration>
  977. </config>
  978. <executionNodeRestricted>false</executionNodeRestricted>
  979. <name>LogAttribute</name>
  980. <relationships>
  981. <autoTerminate>false</autoTerminate>
  982. <name>success</name>
  983. </relationships>
  984. <state>STOPPED</state>
  985. <style/>
  986. <type>org.apache.nifi.processors.standard.LogAttribute</type>
  987. </processors>
  988. </snippet>
  989. <timestamp>08/22/2018 10:56:27 EDT</timestamp>
  990. </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!