API tools faq
paste
Guest User

Untitled

a guest
Jul 18th, 2018
77
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 25.74 KB | None | 0 0
raw download clone embed print report
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <transformation>
  3. <info>
  4. <name>JSONNestedBuild</name>
  5. <description>Building Nested Logic of a flattened Data - By Rishu Shrivastava</description>
  6. <extended_description>v1.0 INITIAL VERSION 19.07.2018</extended_description>
  7. <trans_version>1.0</trans_version>
  8. <trans_type>Normal</trans_type>
  9. <trans_status>1</trans_status>
  10. <directory>/</directory>
  11. <parameters>
  12. </parameters>
  13. <log>
  14. <trans-log-table>
  15. <connection />
  16. <schema />
  17. <table />
  18. <size_limit_lines />
  19. <interval />
  20. <timeout_days />
  21. <field>
  22. <id>ID_BATCH</id>
  23. <enabled>Y</enabled>
  24. <name>ID_BATCH</name>
  25. </field>
  26. <field>
  27. <id>CHANNEL_ID</id>
  28. <enabled>Y</enabled>
  29. <name>CHANNEL_ID</name>
  30. </field>
  31. <field>
  32. <id>TRANSNAME</id>
  33. <enabled>Y</enabled>
  34. <name>TRANSNAME</name>
  35. </field>
  36. <field>
  37. <id>STATUS</id>
  38. <enabled>Y</enabled>
  39. <name>STATUS</name>
  40. </field>
  41. <field>
  42. <id>LINES_READ</id>
  43. <enabled>Y</enabled>
  44. <name>LINES_READ</name>
  45. <subject />
  46. </field>
  47. <field>
  48. <id>LINES_WRITTEN</id>
  49. <enabled>Y</enabled>
  50. <name>LINES_WRITTEN</name>
  51. <subject />
  52. </field>
  53. <field>
  54. <id>LINES_UPDATED</id>
  55. <enabled>Y</enabled>
  56. <name>LINES_UPDATED</name>
  57. <subject />
  58. </field>
  59. <field>
  60. <id>LINES_INPUT</id>
  61. <enabled>Y</enabled>
  62. <name>LINES_INPUT</name>
  63. <subject />
  64. </field>
  65. <field>
  66. <id>LINES_OUTPUT</id>
  67. <enabled>Y</enabled>
  68. <name>LINES_OUTPUT</name>
  69. <subject />
  70. </field>
  71. <field>
  72. <id>LINES_REJECTED</id>
  73. <enabled>Y</enabled>
  74. <name>LINES_REJECTED</name>
  75. <subject />
  76. </field>
  77. <field>
  78. <id>ERRORS</id>
  79. <enabled>Y</enabled>
  80. <name>ERRORS</name>
  81. </field>
  82. <field>
  83. <id>STARTDATE</id>
  84. <enabled>Y</enabled>
  85. <name>STARTDATE</name>
  86. </field>
  87. <field>
  88. <id>ENDDATE</id>
  89. <enabled>Y</enabled>
  90. <name>ENDDATE</name>
  91. </field>
  92. <field>
  93. <id>LOGDATE</id>
  94. <enabled>Y</enabled>
  95. <name>LOGDATE</name>
  96. </field>
  97. <field>
  98. <id>DEPDATE</id>
  99. <enabled>Y</enabled>
  100. <name>DEPDATE</name>
  101. </field>
  102. <field>
  103. <id>REPLAYDATE</id>
  104. <enabled>Y</enabled>
  105. <name>REPLAYDATE</name>
  106. </field>
  107. <field>
  108. <id>LOG_FIELD</id>
  109. <enabled>Y</enabled>
  110. <name>LOG_FIELD</name>
  111. </field>
  112. <field>
  113. <id>EXECUTING_SERVER</id>
  114. <enabled>N</enabled>
  115. <name>EXECUTING_SERVER</name>
  116. </field>
  117. <field>
  118. <id>EXECUTING_USER</id>
  119. <enabled>N</enabled>
  120. <name>EXECUTING_USER</name>
  121. </field>
  122. <field>
  123. <id>CLIENT</id>
  124. <enabled>N</enabled>
  125. <name>CLIENT</name>
  126. </field>
  127. </trans-log-table>
  128. <perf-log-table>
  129. <connection />
  130. <schema />
  131. <table />
  132. <interval />
  133. <timeout_days />
  134. <field>
  135. <id>ID_BATCH</id>
  136. <enabled>Y</enabled>
  137. <name>ID_BATCH</name>
  138. </field>
  139. <field>
  140. <id>SEQ_NR</id>
  141. <enabled>Y</enabled>
  142. <name>SEQ_NR</name>
  143. </field>
  144. <field>
  145. <id>LOGDATE</id>
  146. <enabled>Y</enabled>
  147. <name>LOGDATE</name>
  148. </field>
  149. <field>
  150. <id>TRANSNAME</id>
  151. <enabled>Y</enabled>
  152. <name>TRANSNAME</name>
  153. </field>
  154. <field>
  155. <id>STEPNAME</id>
  156. <enabled>Y</enabled>
  157. <name>STEPNAME</name>
  158. </field>
  159. <field>
  160. <id>STEP_COPY</id>
  161. <enabled>Y</enabled>
  162. <name>STEP_COPY</name>
  163. </field>
  164. <field>
  165. <id>LINES_READ</id>
  166. <enabled>Y</enabled>
  167. <name>LINES_READ</name>
  168. </field>
  169. <field>
  170. <id>LINES_WRITTEN</id>
  171. <enabled>Y</enabled>
  172. <name>LINES_WRITTEN</name>
  173. </field>
  174. <field>
  175. <id>LINES_UPDATED</id>
  176. <enabled>Y</enabled>
  177. <name>LINES_UPDATED</name>
  178. </field>
  179. <field>
  180. <id>LINES_INPUT</id>
  181. <enabled>Y</enabled>
  182. <name>LINES_INPUT</name>
  183. </field>
  184. <field>
  185. <id>LINES_OUTPUT</id>
  186. <enabled>Y</enabled>
  187. <name>LINES_OUTPUT</name>
  188. </field>
  189. <field>
  190. <id>LINES_REJECTED</id>
  191. <enabled>Y</enabled>
  192. <name>LINES_REJECTED</name>
  193. </field>
  194. <field>
  195. <id>ERRORS</id>
  196. <enabled>Y</enabled>
  197. <name>ERRORS</name>
  198. </field>
  199. <field>
  200. <id>INPUT_BUFFER_ROWS</id>
  201. <enabled>Y</enabled>
  202. <name>INPUT_BUFFER_ROWS</name>
  203. </field>
  204. <field>
  205. <id>OUTPUT_BUFFER_ROWS</id>
  206. <enabled>Y</enabled>
  207. <name>OUTPUT_BUFFER_ROWS</name>
  208. </field>
  209. </perf-log-table>
  210. <channel-log-table>
  211. <connection />
  212. <schema />
  213. <table />
  214. <timeout_days />
  215. <field>
  216. <id>ID_BATCH</id>
  217. <enabled>Y</enabled>
  218. <name>ID_BATCH</name>
  219. </field>
  220. <field>
  221. <id>CHANNEL_ID</id>
  222. <enabled>Y</enabled>
  223. <name>CHANNEL_ID</name>
  224. </field>
  225. <field>
  226. <id>LOG_DATE</id>
  227. <enabled>Y</enabled>
  228. <name>LOG_DATE</name>
  229. </field>
  230. <field>
  231. <id>LOGGING_OBJECT_TYPE</id>
  232. <enabled>Y</enabled>
  233. <name>LOGGING_OBJECT_TYPE</name>
  234. </field>
  235. <field>
  236. <id>OBJECT_NAME</id>
  237. <enabled>Y</enabled>
  238. <name>OBJECT_NAME</name>
  239. </field>
  240. <field>
  241. <id>OBJECT_COPY</id>
  242. <enabled>Y</enabled>
  243. <name>OBJECT_COPY</name>
  244. </field>
  245. <field>
  246. <id>REPOSITORY_DIRECTORY</id>
  247. <enabled>Y</enabled>
  248. <name>REPOSITORY_DIRECTORY</name>
  249. </field>
  250. <field>
  251. <id>FILENAME</id>
  252. <enabled>Y</enabled>
  253. <name>FILENAME</name>
  254. </field>
  255. <field>
  256. <id>OBJECT_ID</id>
  257. <enabled>Y</enabled>
  258. <name>OBJECT_ID</name>
  259. </field>
  260. <field>
  261. <id>OBJECT_REVISION</id>
  262. <enabled>Y</enabled>
  263. <name>OBJECT_REVISION</name>
  264. </field>
  265. <field>
  266. <id>PARENT_CHANNEL_ID</id>
  267. <enabled>Y</enabled>
  268. <name>PARENT_CHANNEL_ID</name>
  269. </field>
  270. <field>
  271. <id>ROOT_CHANNEL_ID</id>
  272. <enabled>Y</enabled>
  273. <name>ROOT_CHANNEL_ID</name>
  274. </field>
  275. </channel-log-table>
  276. <step-log-table>
  277. <connection />
  278. <schema />
  279. <table />
  280. <timeout_days />
  281. <field>
  282. <id>ID_BATCH</id>
  283. <enabled>Y</enabled>
  284. <name>ID_BATCH</name>
  285. </field>
  286. <field>
  287. <id>CHANNEL_ID</id>
  288. <enabled>Y</enabled>
  289. <name>CHANNEL_ID</name>
  290. </field>
  291. <field>
  292. <id>LOG_DATE</id>
  293. <enabled>Y</enabled>
  294. <name>LOG_DATE</name>
  295. </field>
  296. <field>
  297. <id>TRANSNAME</id>
  298. <enabled>Y</enabled>
  299. <name>TRANSNAME</name>
  300. </field>
  301. <field>
  302. <id>STEPNAME</id>
  303. <enabled>Y</enabled>
  304. <name>STEPNAME</name>
  305. </field>
  306. <field>
  307. <id>STEP_COPY</id>
  308. <enabled>Y</enabled>
  309. <name>STEP_COPY</name>
  310. </field>
  311. <field>
  312. <id>LINES_READ</id>
  313. <enabled>Y</enabled>
  314. <name>LINES_READ</name>
  315. </field>
  316. <field>
  317. <id>LINES_WRITTEN</id>
  318. <enabled>Y</enabled>
  319. <name>LINES_WRITTEN</name>
  320. </field>
  321. <field>
  322. <id>LINES_UPDATED</id>
  323. <enabled>Y</enabled>
  324. <name>LINES_UPDATED</name>
  325. </field>
  326. <field>
  327. <id>LINES_INPUT</id>
  328. <enabled>Y</enabled>
  329. <name>LINES_INPUT</name>
  330. </field>
  331. <field>
  332. <id>LINES_OUTPUT</id>
  333. <enabled>Y</enabled>
  334. <name>LINES_OUTPUT</name>
  335. </field>
  336. <field>
  337. <id>LINES_REJECTED</id>
  338. <enabled>Y</enabled>
  339. <name>LINES_REJECTED</name>
  340. </field>
  341. <field>
  342. <id>ERRORS</id>
  343. <enabled>Y</enabled>
  344. <name>ERRORS</name>
  345. </field>
  346. <field>
  347. <id>LOG_FIELD</id>
  348. <enabled>N</enabled>
  349. <name>LOG_FIELD</name>
  350. </field>
  351. </step-log-table>
  352. <metrics-log-table>
  353. <connection />
  354. <schema />
  355. <table />
  356. <timeout_days />
  357. <field>
  358. <id>ID_BATCH</id>
  359. <enabled>Y</enabled>
  360. <name>ID_BATCH</name>
  361. </field>
  362. <field>
  363. <id>CHANNEL_ID</id>
  364. <enabled>Y</enabled>
  365. <name>CHANNEL_ID</name>
  366. </field>
  367. <field>
  368. <id>LOG_DATE</id>
  369. <enabled>Y</enabled>
  370. <name>LOG_DATE</name>
  371. </field>
  372. <field>
  373. <id>METRICS_DATE</id>
  374. <enabled>Y</enabled>
  375. <name>METRICS_DATE</name>
  376. </field>
  377. <field>
  378. <id>METRICS_CODE</id>
  379. <enabled>Y</enabled>
  380. <name>METRICS_CODE</name>
  381. </field>
  382. <field>
  383. <id>METRICS_DESCRIPTION</id>
  384. <enabled>Y</enabled>
  385. <name>METRICS_DESCRIPTION</name>
  386. </field>
  387. <field>
  388. <id>METRICS_SUBJECT</id>
  389. <enabled>Y</enabled>
  390. <name>METRICS_SUBJECT</name>
  391. </field>
  392. <field>
  393. <id>METRICS_TYPE</id>
  394. <enabled>Y</enabled>
  395. <name>METRICS_TYPE</name>
  396. </field>
  397. <field>
  398. <id>METRICS_VALUE</id>
  399. <enabled>Y</enabled>
  400. <name>METRICS_VALUE</name>
  401. </field>
  402. </metrics-log-table>
  403. </log>
  404. <maxdate>
  405. <connection />
  406. <table />
  407. <field />
  408. <offset>0.0</offset>
  409. <maxdiff>0.0</maxdiff>
  410. </maxdate>
  411. <size_rowset>10000</size_rowset>
  412. <sleep_time_empty>50</sleep_time_empty>
  413. <sleep_time_full>50</sleep_time_full>
  414. <unique_connections>N</unique_connections>
  415. <feedback_shown>Y</feedback_shown>
  416. <feedback_size>50000</feedback_size>
  417. <using_thread_priorities>Y</using_thread_priorities>
  418. <shared_objects_file />
  419. <capture_step_performance>N</capture_step_performance>
  420. <step_performance_capturing_delay>1000</step_performance_capturing_delay>
  421. <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
  422. <dependencies>
  423. </dependencies>
  424. <partitionschemas>
  425. </partitionschemas>
  426. <slaveservers>
  427. </slaveservers>
  428. <clusterschemas>
  429. </clusterschemas>
  430. <created_user>-</created_user>
  431. <created_date>2018/07/19 01:15:04.786</created_date>
  432. <modified_user>-</modified_user>
  433. <modified_date>2018/07/19 01:15:04.786</modified_date>
  434. <key_for_session_key />
  435. <is_key_private>N</is_key_private>
  436. </info>
  437. <notepads>
  438. <notepad>
  439. <note>Nested JSON Output</note>
  440. <xloc>448</xloc>
  441. <yloc>16</yloc>
  442. <width>120</width>
  443. <heigth>26</heigth>
  444. <fontname>Segoe UI</fontname>
  445. <fontsize>9</fontsize>
  446. <fontbold>N</fontbold>
  447. <fontitalic>N</fontitalic>
  448. <fontcolorred>0</fontcolorred>
  449. <fontcolorgreen>0</fontcolorgreen>
  450. <fontcolorblue>0</fontcolorblue>
  451. <backgroundcolorred>255</backgroundcolorred>
  452. <backgroundcolorgreen>205</backgroundcolorgreen>
  453. <backgroundcolorblue>112</backgroundcolorblue>
  454. <bordercolorred>100</bordercolorred>
  455. <bordercolorgreen>100</bordercolorgreen>
  456. <bordercolorblue>100</bordercolorblue>
  457. <drawshadow>Y</drawshadow>
  458. </notepad>
  459. </notepads>
  460. <connection>
  461. <name>MySQL Source</name>
  462. <server>localhost</server>
  463. <type>MYSQL</type>
  464. <access>Native</access>
  465. <database>sakila</database>
  466. <port>3306</port>
  467. <username>root</username>
  468. <password>Encrypted 2be98afc86aa7f2e4bb18bd63c99dbdde</password>
  469. <servername />
  470. <data_tablespace />
  471. <index_tablespace />
  472. <attributes>
  473. <attribute>
  474. <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
  475. <attribute>N</attribute>
  476. </attribute>
  477. <attribute>
  478. <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
  479. <attribute>N</attribute>
  480. </attribute>
  481. <attribute>
  482. <code>IS_CLUSTERED</code>
  483. <attribute>N</attribute>
  484. </attribute>
  485. <attribute>
  486. <code>PORT_NUMBER</code>
  487. <attribute>3306</attribute>
  488. </attribute>
  489. <attribute>
  490. <code>PRESERVE_RESERVED_WORD_CASE</code>
  491. <attribute>Y</attribute>
  492. </attribute>
  493. <attribute>
  494. <code>QUOTE_ALL_FIELDS</code>
  495. <attribute>N</attribute>
  496. </attribute>
  497. <attribute>
  498. <code>STREAM_RESULTS</code>
  499. <attribute>Y</attribute>
  500. </attribute>
  501. <attribute>
  502. <code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
  503. <attribute>Y</attribute>
  504. </attribute>
  505. <attribute>
  506. <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
  507. <attribute>Y</attribute>
  508. </attribute>
  509. <attribute>
  510. <code>USE_POOLING</code>
  511. <attribute>N</attribute>
  512. </attribute>
  513. </attributes>
  514. </connection>
  515. <order>
  516. <hop>
  517. <from>Actor</from>
  518. <to>Find Actors</to>
  519. <enabled>Y</enabled>
  520. </hop>
  521. <hop>
  522. <from>Actors in Films</from>
  523. <to>Find Actors</to>
  524. <enabled>Y</enabled>
  525. </hop>
  526. <hop>
  527. <from>Find Actors</from>
  528. <to>Find Film Names</to>
  529. <enabled>Y</enabled>
  530. </hop>
  531. <hop>
  532. <from>Film</from>
  533. <to>Find Film Names</to>
  534. <enabled>Y</enabled>
  535. </hop>
  536. <hop>
  537. <from>Find Film Names</from>
  538. <to>Select values</to>
  539. <enabled>Y</enabled>
  540. </hop>
  541. <hop>
  542. <from>Select values</from>
  543. <to>Filter 2 Actors</to>
  544. <enabled>Y</enabled>
  545. </hop>
  546. <hop>
  547. <from>Filter 2 Actors</from>
  548. <to>Aggregate Data</to>
  549. <enabled>Y</enabled>
  550. </hop>
  551. <hop>
  552. <from>Aggregate Data</from>
  553. <to>Build JS</to>
  554. <enabled>Y</enabled>
  555. </hop>
  556. <hop>
  557. <from>Build JS</from>
  558. <to>Output JSON</to>
  559. <enabled>Y</enabled>
  560. </hop>
  561. </order>
  562. <step>
  563. <name>Actor</name>
  564. <type>TableInput</type>
  565. <description />
  566. <distribute>Y</distribute>
  567. <custom_distribution />
  568. <copies>1</copies>
  569. <partitioning>
  570. <method>none</method>
  571. <schema_name />
  572. </partitioning>
  573. <connection>MySQL Source</connection>
  574. <sql>SELECT
  575. actor_id
  576. , first_name
  577. , last_name
  578. , last_update
  579. FROM actor
  580. </sql>
  581. <limit>0</limit>
  582. <lookup />
  583. <execute_each_row>N</execute_each_row>
  584. <variables_active>N</variables_active>
  585. <lazy_conversion_active>N</lazy_conversion_active>
  586. <cluster_schema />
  587. <remotesteps>
  588. <input>
  589. </input>
  590. <output>
  591. </output>
  592. </remotesteps>
  593. <GUI>
  594. <xloc>176</xloc>
  595. <yloc>64</yloc>
  596. <draw>Y</draw>
  597. </GUI>
  598. </step>
  599. <step>
  600. <name>Actors in Films</name>
  601. <type>TableInput</type>
  602. <description />
  603. <distribute>Y</distribute>
  604. <custom_distribution />
  605. <copies>1</copies>
  606. <partitioning>
  607. <method>none</method>
  608. <schema_name />
  609. </partitioning>
  610. <connection>MySQL Source</connection>
  611. <sql>SELECT
  612. actor_id
  613. , film_id
  614. , last_update
  615. FROM film_actor
  616. </sql>
  617. <limit>0</limit>
  618. <lookup />
  619. <execute_each_row>N</execute_each_row>
  620. <variables_active>N</variables_active>
  621. <lazy_conversion_active>N</lazy_conversion_active>
  622. <cluster_schema />
  623. <remotesteps>
  624. <input>
  625. </input>
  626. <output>
  627. </output>
  628. </remotesteps>
  629. <GUI>
  630. <xloc>64</xloc>
  631. <yloc>160</yloc>
  632. <draw>Y</draw>
  633. </GUI>
  634. </step>
  635. <step>
  636. <name>Find Actors</name>
  637. <type>StreamLookup</type>
  638. <description />
  639. <distribute>Y</distribute>
  640. <custom_distribution />
  641. <copies>1</copies>
  642. <partitioning>
  643. <method>none</method>
  644. <schema_name />
  645. </partitioning>
  646. <from>Actor</from>
  647. <input_sorted>N</input_sorted>
  648. <preserve_memory>Y</preserve_memory>
  649. <sorted_list>N</sorted_list>
  650. <integer_pair>N</integer_pair>
  651. <lookup>
  652. <key>
  653. <name>actor_id</name>
  654. <field>actor_id</field>
  655. </key>
  656. <value>
  657. <name>first_name</name>
  658. <rename>first_name</rename>
  659. <default />
  660. <type>String</type>
  661. </value>
  662. <value>
  663. <name>last_name</name>
  664. <rename>last_name</rename>
  665. <default />
  666. <type>String</type>
  667. </value>
  668. <value>
  669. <name>last_update</name>
  670. <rename>last_update</rename>
  671. <default />
  672. <type>Timestamp</type>
  673. </value>
  674. </lookup>
  675. <cluster_schema />
  676. <remotesteps>
  677. <input>
  678. </input>
  679. <output>
  680. </output>
  681. </remotesteps>
  682. <GUI>
  683. <xloc>176</xloc>
  684. <yloc>160</yloc>
  685. <draw>Y</draw>
  686. </GUI>
  687. </step>
  688. <step>
  689. <name>Find Film Names</name>
  690. <type>StreamLookup</type>
  691. <description />
  692. <distribute>Y</distribute>
  693. <custom_distribution />
  694. <copies>1</copies>
  695. <partitioning>
  696. <method>none</method>
  697. <schema_name />
  698. </partitioning>
  699. <from>Film</from>
  700. <input_sorted>N</input_sorted>
  701. <preserve_memory>Y</preserve_memory>
  702. <sorted_list>N</sorted_list>
  703. <integer_pair>N</integer_pair>
  704. <lookup>
  705. <key>
  706. <name>film_id</name>
  707. <field>film_id</field>
  708. </key>
  709. <value>
  710. <name>title</name>
  711. <rename>title</rename>
  712. <default />
  713. <type>String</type>
  714. </value>
  715. <value>
  716. <name>description</name>
  717. <rename>description</rename>
  718. <default />
  719. <type>String</type>
  720. </value>
  721. </lookup>
  722. <cluster_schema />
  723. <remotesteps>
  724. <input>
  725. </input>
  726. <output>
  727. </output>
  728. </remotesteps>
  729. <GUI>
  730. <xloc>304</xloc>
  731. <yloc>160</yloc>
  732. <draw>Y</draw>
  733. </GUI>
  734. </step>
  735. <step>
  736. <name>Film</name>
  737. <type>TableInput</type>
  738. <description />
  739. <distribute>Y</distribute>
  740. <custom_distribution />
  741. <copies>1</copies>
  742. <partitioning>
  743. <method>none</method>
  744. <schema_name />
  745. </partitioning>
  746. <connection>MySQL Source</connection>
  747. <sql>SELECT
  748. film_id
  749. , title
  750. , description
  751. FROM film
  752. </sql>
  753. <limit>0</limit>
  754. <lookup />
  755. <execute_each_row>N</execute_each_row>
  756. <variables_active>N</variables_active>
  757. <lazy_conversion_active>N</lazy_conversion_active>
  758. <cluster_schema />
  759. <remotesteps>
  760. <input>
  761. </input>
  762. <output>
  763. </output>
  764. </remotesteps>
  765. <GUI>
  766. <xloc>304</xloc>
  767. <yloc>64</yloc>
  768. <draw>Y</draw>
  769. </GUI>
  770. </step>
  771. <step>
  772. <name>Select values</name>
  773. <type>SelectValues</type>
  774. <description />
  775. <distribute>Y</distribute>
  776. <custom_distribution />
  777. <copies>1</copies>
  778. <partitioning>
  779. <method>none</method>
  780. <schema_name />
  781. </partitioning>
  782. <fields>
  783. <field>
  784. <name>actor_id</name>
  785. <rename />
  786. </field>
  787. <field>
  788. <name>first_name</name>
  789. <rename />
  790. </field>
  791. <field>
  792. <name>last_name</name>
  793. <rename />
  794. </field>
  795. <field>
  796. <name>film_id</name>
  797. <rename />
  798. </field>
  799. <field>
  800. <name>title</name>
  801. <rename />
  802. </field>
  803. <field>
  804. <name>description</name>
  805. <rename />
  806. </field>
  807. <select_unspecified>N</select_unspecified>
  808. </fields>
  809. <cluster_schema />
  810. <remotesteps>
  811. <input>
  812. </input>
  813. <output>
  814. </output>
  815. </remotesteps>
  816. <GUI>
  817. <xloc>400</xloc>
  818. <yloc>160</yloc>
  819. <draw>Y</draw>
  820. </GUI>
  821. </step>
  822. <step>
  823. <name>Filter 2 Actors</name>
  824. <type>FilterRows</type>
  825. <description />
  826. <distribute>Y</distribute>
  827. <custom_distribution />
  828. <copies>1</copies>
  829. <partitioning>
  830. <method>none</method>
  831. <schema_name />
  832. </partitioning>
  833. <send_true_to>Aggregate Data</send_true_to>
  834. <send_false_to />
  835. <compare>
  836. <condition>
  837. <negated>N</negated>
  838. <conditions>
  839. <condition>
  840. <negated>N</negated>
  841. <leftvalue>actor_id</leftvalue>
  842. <function><=</function>
  843. <rightvalue />
  844. <value>
  845. <name>constant</name>
  846. <type>Integer</type>
  847. <text>2</text>
  848. <length>-1</length>
  849. <precision>0</precision>
  850. <isnull>N</isnull>
  851. <mask>####0;-####0</mask>
  852. </value>
  853. </condition>
  854. </conditions>
  855. </condition>
  856. </compare>
  857. <cluster_schema />
  858. <remotesteps>
  859. <input>
  860. </input>
  861. <output>
  862. </output>
  863. </remotesteps>
  864. <GUI>
  865. <xloc>496</xloc>
  866. <yloc>160</yloc>
  867. <draw>Y</draw>
  868. </GUI>
  869. </step>
  870. <step>
  871. <name>Build JS</name>
  872. <type>ScriptValueMod</type>
  873. <description />
  874. <distribute>Y</distribute>
  875. <custom_distribution />
  876. <copies>1</copies>
  877. <partitioning>
  878. <method>none</method>
  879. <schema_name />
  880. </partitioning>
  881. <compatible>N</compatible>
  882. <optimizationLevel>9</optimizationLevel>
  883. <jsScripts>
  884. <jsScript>
  885. <jsScript_type>0</jsScript_type>
  886. <jsScript_name>Script 1</jsScript_name>
  887. <jsScript_script>//Script here
  888.  
  889. var json = {};
  890. json.movie={};
  891. Child_Accounts = [];
  892.  
  893. var split_film_id =[];
  894. var split_title =[];
  895. var split_descr =[];
  896.  
  897. json.movie.actor_id = actor_id;
  898. json.movie.first_name = first_name;
  899. json.movie.last_name = last_name;
  900.  
  901.  
  902. split_film_id = film_id.split(';');
  903. split_title = title.split(';');
  904.  
  905.  
  906. for(i=0; i<split_film_id.length; i++){
  907.  
  908. var childCol = {};
  909.  
  910. childCol.film_id=split_film_id[i];
  911. childCol.title=split_title[i];
  912.  
  913. Child_Accounts.push(childCol);
  914.  
  915.  
  916. }
  917.  
  918. json.movie.films=Child_Accounts;
  919.  
  920.  
  921.  
  922. var JsonOutput = JSON.stringify(json);</jsScript_script>
  923. </jsScript>
  924. </jsScripts>
  925. <fields>
  926. <field>
  927. <name>JsonOutput</name>
  928. <rename>JsonOutput</rename>
  929. <type>String</type>
  930. <length>-1</length>
  931. <precision>-1</precision>
  932. <replace>N</replace>
  933. </field>
  934. </fields>
  935. <cluster_schema />
  936. <remotesteps>
  937. <input>
  938. </input>
  939. <output>
  940. </output>
  941. </remotesteps>
  942. <GUI>
  943. <xloc>720</xloc>
  944. <yloc>160</yloc>
  945. <draw>Y</draw>
  946. </GUI>
  947. </step>
  948. <step>
  949. <name>Aggregate Data</name>
  950. <type>MemoryGroupBy</type>
  951. <description />
  952. <distribute>Y</distribute>
  953. <custom_distribution />
  954. <copies>1</copies>
  955. <partitioning>
  956. <method>none</method>
  957. <schema_name />
  958. </partitioning>
  959. <give_back_row>N</give_back_row>
  960. <group>
  961. <field>
  962. <name>actor_id</name>
  963. </field>
  964. <field>
  965. <name>first_name</name>
  966. </field>
  967. <field>
  968. <name>last_name</name>
  969. </field>
  970. </group>
  971. <fields>
  972. <field>
  973. <aggregate>film_id</aggregate>
  974. <subject>film_id</subject>
  975. <type>CONCAT_STRING</type>
  976. <valuefield>;</valuefield>
  977. </field>
  978. <field>
  979. <aggregate>title</aggregate>
  980. <subject>title</subject>
  981. <type>CONCAT_STRING</type>
  982. <valuefield>;</valuefield>
  983. </field>
  984. <field>
  985. <aggregate>description</aggregate>
  986. <subject>description</subject>
  987. <type>CONCAT_STRING</type>
  988. <valuefield>;</valuefield>
  989. </field>
  990. </fields>
  991. <cluster_schema />
  992. <remotesteps>
  993. <input>
  994. </input>
  995. <output>
  996. </output>
  997. </remotesteps>
  998. <GUI>
  999. <xloc>608</xloc>
  1000. <yloc>160</yloc>
  1001. <draw>Y</draw>
  1002. </GUI>
  1003. </step>
  1004. <step>
  1005. <name>Output JSON</name>
  1006. <type>TextFileOutput</type>
  1007. <description />
  1008. <distribute>Y</distribute>
  1009. <custom_distribution />
  1010. <copies>1</copies>
  1011. <partitioning>
  1012. <method>none</method>
  1013. <schema_name />
  1014. </partitioning>
  1015. <separator>,</separator>
  1016. <enclosure />
  1017. <enclosure_forced>N</enclosure_forced>
  1018. <enclosure_fix_disabled>N</enclosure_fix_disabled>
  1019. <header>N</header>
  1020. <footer>N</footer>
  1021. <format>DOS</format>
  1022. <compression>None</compression>
  1023. <encoding />
  1024. <endedLine />
  1025. <fileNameInField>N</fileNameInField>
  1026. <fileNameField />
  1027. <create_parent_folder>Y</create_parent_folder>
  1028. <file>
  1029. <name>C:\Users\Rishu\Desktop\JSONOutput</name>
  1030. <is_command>N</is_command>
  1031. <servlet_output>N</servlet_output>
  1032. <do_not_open_new_file_init>N</do_not_open_new_file_init>
  1033. <extention>js</extention>
  1034. <append>N</append>
  1035. <split>N</split>
  1036. <haspartno>N</haspartno>
  1037. <add_date>N</add_date>
  1038. <add_time>N</add_time>
  1039. <SpecifyFormat>N</SpecifyFormat>
  1040. <date_time_format />
  1041. <add_to_result_filenames>Y</add_to_result_filenames>
  1042. <pad>N</pad>
  1043. <fast_dump>N</fast_dump>
  1044. <splitevery>0</splitevery>
  1045. </file>
  1046. <fields>
  1047. <field>
  1048. <name>JsonOutput</name>
  1049. <type>String</type>
  1050. <format />
  1051. <currency />
  1052. <decimal />
  1053. <group />
  1054. <nullif />
  1055. <trim_type>none</trim_type>
  1056. <length>-1</length>
  1057. <precision>-1</precision>
  1058. </field>
  1059. </fields>
  1060. <cluster_schema />
  1061. <remotesteps>
  1062. <input>
  1063. </input>
  1064. <output>
  1065. </output>
  1066. </remotesteps>
  1067. <GUI>
  1068. <xloc>848</xloc>
  1069. <yloc>160</yloc>
  1070. <draw>Y</draw>
  1071. </GUI>
  1072. </step>
  1073. <step_error_handling>
  1074. </step_error_handling>
  1075. <slave-step-copy-partition-distribution>
  1076. </slave-step-copy-partition-distribution>
  1077. <slave_transformation>N</slave_transformation>
  1078. </transformation>
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!