All Examples

  1. Add Array Fields to Entities DataPipeline Foundations Schema
  2. Add Attributes and Tags to Schemas DataPipeline Foundations Schema
  3. Add Calculated Fields to a Decision Table DataPipeline Foundations Decision Table Calculated Field
  4. Add Calculated Fields to a Decision Tree DataPipeline Foundations Calculated Field Decision Tree
  5. Add Indexes to Entities DataPipeline Foundations Schema
  6. Add Jira Comments Jira
  7. Add Nested Entities as Fields DataPipeline Foundations Schema
  8. Add Non-Persistent Data to Records and Fields In-Memory Out-of-band data
  9. Add Primary Keys to Entities DataPipeline Foundations Schema
  10. Add Relationship Between Entities DataPipeline Foundations Schema
  11. Add a Decision Table to a Pipeline DataPipeline Foundations Decision Table
  12. Add a Decision Tree to a Pipeline DataPipeline Foundations Decision Tree
  13. Add a Sequence Number Column Transform Calculated Field Assign Field
  14. Add a Sequence Number Column for Repeat Values Transform Calculated Field Assign Field
  15. Add a Sequence Number Column when Values Change Transform Calculated Field Assign Field
  16. Add my own Functions Customize Expression Language Assign Field Functions
  17. Automatically Map Data And Exclude Fields Declaratively Version 8.1.0 DataPipeline Foundations XML Declarative Data Mapping
  18. Blacklist and Whitelist Functions in DP Expression Language Customize Expression Language Functions
  19. Buffer Records by Time Period or Count Streaming data
  20. Build DataMappingPipeline Declaratively from Json DataPipeline Foundations Declarative Data Mapping JSON
  21. Build DataMappingPipeline Declaratively from XML DataPipeline Foundations XML Declarative Data Mapping
  22. Build DataMappingPipeline Programmatically DataPipeline Foundations Data Mapping
  23. Cache Lookup Values Lookup Transform JDBC Cache
  24. Capture Data Not Joined in a Lookup Lookup
  25. Capture Data that Failed Data Mapping Validation DataPipeline Foundations Data Mapping
  26. Compare Schemas Using Diff DataPipeline Foundations Schema
  27. Compile and Run a Job Job management CSV Fixed Width
  28. Compress a Parquet File Parquet
  29. Compress an Orc File ORC
  30. Conditionally Map Data Field from Source to Target DataPipeline Foundations Data Mapping
  31. Conditionally Transform Data Simple Transform Filter JSON Assign Field
  32. Conditionally Write to Multiple Files Transform Multi-writer Threading
  33. Conditionally map Data from Source to Target DataPipeline Foundations Data Mapping
  34. Configure AmazonS3FileSystem Using Client Amazon S3
  35. Configure the Insert Strategy used in JdbcMultiWriter Version 8.1.0 JDBC Multi-Writer JDBC Insert Strategy JDBC
  36. Continue After an Error Exceptions
  37. Convert JSON to CSV Simple CSV Conversion JSON
  38. Convert JSON to Parquet Parquet Conversion JSON
  39. Convert Unstructured JSON to Parquet Parquet Conversion JSON
  40. Convert a Single Source DataReader into Many XML Simple Conversion Avro Threading JSON
  41. Copy a Field Copy Field Transform
  42. Create Custom Pipeline Action Customize DataPipeline Foundations Pipeline
  43. Create Custom Pipeline Input DataPipeline Foundations Pipeline
  44. Create Custom Pipeline Output DataPipeline Foundations Pipeline
  45. Create Jira Issue Jira
  46. Create a JsonPipelineInput Declaratively From Xml DataPipeline Foundations XML Declarative Pipeline
  47. Create a JsonPipelineInput Declaratively from JSON DataPipeline Foundations Declarative Pipeline JSON
  48. Create a JsonPipelineInput Programmatically DataPipeline Foundations Pipeline
  49. Create an XmlPipelineInput Declaratively From Xml DataPipeline Foundations XML Declarative Pipeline
  50. Create an XmlPipelineInput Declaratively from Json DataPipeline Foundations Declarative Pipeline JSON
  51. Create an XmlPipelineInput Programmatically DataPipeline Foundations Pipeline
  52. Debug my Code Debug
  53. Declaratively Map Data DataPipeline Foundations Declarative Data Mapping
  54. Declaratively Map Data Using Positions DataPipeline Foundations Declarative Data Mapping
  55. Declaratively Map Data with Source and Target Schema DataPipeline Foundations Declarative Data Mapping Schema
  56. Declaratively Map XML Files DataPipeline Foundations XML Declarative Data Mapping
  57. Declaratively Set Default Values for Missing Data DataPipeline Foundations Declarative Schema
  58. Declaratively Transform Records using Schema DataPipeline Foundations Declarative Schema
  59. Delete Jira Issue Jira
  60. Detect Date and Time Patterns in Strings DataPipeline Foundations Analyze Data
  61. Detect Numbers in Strings DataPipeline Foundations Analyze Data
  62. Detect Primary Keys In a Dataset DataPipeline Foundations Schema Dataset
  63. Evaluate a Decision Table DataPipeline Foundations Decision Table
  64. Evaluate a Decision Table with Lookup DataPipeline Foundations Lookup Decision Table
  65. Evaluate a Decision Tree DataPipeline Foundations Decision Tree
  66. Evaluate a Decision Tree with Lookup DataPipeline Foundations Lookup Decision Tree
  67. Execute an Action in a Decision Table DataPipeline Foundations Decision Table
  68. Execute an Action in a Decision Tree DataPipeline Foundations Decision Tree
  69. Extract Bigrams, Trigrams, and Ngrams XML Transform Analyze Data
  70. Filter Columns with All Null Values DataPipeline Foundations Pipeline
  71. Filter Json Records in a Pipeline DataPipeline Foundations Pipeline Filter
  72. Filter Json Records in a Pipeline Declaratively from Json DataPipeline Foundations Declarative Pipeline Filter JSON
  73. Filter Json Records in a Pipeline Declaratively from Xml DataPipeline Foundations XML Declarative Pipeline Filter
  74. Filter Records Rules Transform Expression Language Filter
  75. Filter Twitter in Real Time Streaming data Filter Twitter
  76. Filter Twitter in Real Time Using v2 API Twitter2 Streaming data Filter
  77. Find The Minimum Maximum Average Sum Count Stats Transform CSV Conversion Aggregate STDOUT
  78. Generate Java Beans from a Database DataPipeline Foundations JDBC Code Generation
  79. Generate Parquet Schema By Analyzing All Records Parquet CSV
  80. Generate Parquet Schema By Analyzing Initial Records Parquet CSV
  81. Generate PostgreSQL DDL From Excel DataPipeline Foundations MS Excel PostgreSQL Code Generation Schema
  82. Generate PostgreSql DDL From CSV DataPipeline Foundations CSV PostgreSQL Code Generation Schema
  83. Generate SQL Queries Programmatically MySQL Microsoft SQL Server JDBC PostgreSQL
  84. Generate Schema From JDBC DataPipeline Foundations JDBC Schema
  85. Generate Schema Java Code DataPipeline Foundations Code Generation Schema
  86. Generate Union and Sub-Select SQL Queries Programmatically MySQL Microsoft SQL Server JDBC PostgreSQL
  87. Generate a PDF XML Simple PDF
  88. Generate a Word Document Simple RTF JSON
  89. Get a Query Param from a URL Transform Assign Field
  90. Group Records by TimePeriod or Count Aggregate
  91. Handle Exceptions Exceptions
  92. Handle Filtered Records Transform Fixed Width Filter Calculated Field Assign Field
  93. Handle Transforming Reader Failures Exceptions XML Transform Rename Field Filter
  94. Handle Transforming Writer Failures Exceptions Transform Conversion Fixed Width Filter Calculated Field
  95. Handle Validation Failures XML Validate Filter
  96. How to Convert Tabular Data to Trees Using Aggregation Transform CSV Sort
  97. Insert Multiple Rows to Oracle Using Insert All Oracle Database Version 8.1.0 JDBC Insert Strategy JDBC
  98. Insert Multiple Rows to Oracle Using Select Union Oracle Database Version 8.1.0 JDBC Insert Strategy JDBC
  99. Load Snapshot of Dataset DataPipeline Foundations Pipeline
  100. Log Diagnostic Information Debug
  101. Log Job Progress Job management STDOUT
  102. Look Up Jira Transition IDs Jira
  103. Lookup Data in a Database Lookup Transform JDBC
  104. Lookup Data in any Data Reader Lookup Transform
  105. Lookup in a Flat File Lookup Transform
  106. Manipulate Fields Transform Conversion In-Memory
  107. Map Data Using Automatic Mapping And Exclude Fields Version 8.1.0 DataPipeline Foundations CSV Data Mapping
  108. Map Data from Source to Target DataPipeline Foundations Data Mapping
  109. Map Data from Source to Target in a Pipeline DataPipeline Foundations Data Mapping
  110. Map Data from Source to Target in a Pipeline with Validation DataPipeline Foundations Data Mapping
  111. Map Data from Source to Target with Lookup DataPipeline Foundations Data Mapping
  112. Map Data with Rule Based Validation DataPipeline Foundations Data Mapping
  113. Map Data with Schema Based Validation DataPipeline Foundations Data Mapping
  114. Map Records in Pipeline using Schema DataPipeline Foundations Pipeline Schema
  115. Map Records using Schema DataPipeline Foundations Schema
  116. Measure Data Lineage Performance Debug Data Lineage Performance
  117. Measure Data being Read and Written Meter
  118. Measure Performance of Reader and Writer Performance
  119. My Data Reader Customize
  120. My Data Writer Customize
  121. My Filter Customize Filter
  122. My Lookup Customize Lookup
  123. My Proxy Reader Customize Transform
  124. My Proxy Writer Customize Transform
  125. My Transformer Customize Transform
  126. Obtain Statistics Stats MS Excel Meter
  127. Open and Close Several Data Readers and Data Writers at Once JDBC
  128. Pipe a Writer to a Reader Pipe Push Threading
  129. Profile Performance Performance
  130. Read A CSV File using Multithreading CSV Threading
  131. Read An ORC file from Amazon S3 Amazon S3 ORC
  132. Read An ORC file from Amazon S3 using a Temporary File Amazon S3 ORC
  133. Read Big Decimal In JSON JSON
  134. Read BigDecimal and BigInteger from an Excel file MS Excel
  135. Read Concatenated JSON JSON
  136. Read Emails Email STDOUT
  137. Read Google Analytics Social Interactions Google
  138. Read Google Analytics goal conversions Google
  139. Read Google Analytics views Google
  140. Read Google Calendar Google
  141. Read Google Contacts Google
  142. Read Google Gmail Messages Email Google
  143. Read JSON Records From File JSON
  144. Read Jira Comments Jira
  145. Read Jira issues Jira
  146. Read Json Lines JSON Lines JSON
  147. Read Json Lines As Record JSON Lines JSON
  148. Read MailChimp Contacts MailChimp
  149. Read MailChimp Contacts Using the RESTful Client API MailChimp
  150. Read Parquet from Amazon S3 Parquet Amazon S3
  151. Read Parquet from Amazon S3 using a Temporary File Parquet Amazon S3
  152. Read Selected Fields from a Parquet File Parquet
  153. Read Selected Fields from an Orc File ORC
  154. Read Trello Cards Trello
  155. Read Tweets from a User's Timeline Using v2 API Twitter2 STDOUT Twitter
  156. Read XML Records From File XML
  157. Read a Bloomberg Message File Bloomberg
  158. Read a CSV File CSV
  159. Read a Fixed-width File / Fixed-length Record File Fixed Width
  160. Read a JSON Stream Conversion XPath STDOUT JSON
  161. Read a Parquet File Parquet
  162. Read a Patient File Simple CSV
  163. Read a Set of Files CSV Batch
  164. Read a Simple JSON File Simple JSON
  165. Read a Simple XML File XML Simple
  166. Read a Web Server Log Web Server Logs STDOUT
  167. Read an Avro File Avro
  168. Read an Orc File ORC
  169. Read an XML File XML XPath
  170. Read an XML File (2) XML Transform Conversion XPath JDBC
  171. Read and Transform Data in Parallel Transform Threading
  172. Read and Write Unsigned Numbers in Parquet Files Version 8.1.0 Parquet
  173. Read and Write to an EventBus EventBus Threading
  174. Read from Amazon S3 Amazon S3
  175. Read from CSV And Writer to Excel DataPipeline Foundations Pipeline
  176. Read from Gmail Email STDOUT
  177. Read from JMS Queue JMS In-Memory
  178. Read from JMS Topic JMS In-Memory
  179. Read from Java beans XPath Java Beans
  180. Read from Memory CSV In-Memory
  181. Read from MongoDB CSV STDOUT MongoDB
  182. Read from a Database JDBC
  183. Read from an Excel File MS Excel
  184. Read from database using OPINIONATED type mapping JDBC
  185. Read from database using ORIGINAL type mapping JDBC
  186. Read from database using STRICT type mapping JDBC
  187. Read using TimedReader Performance
  188. Remove Duplicates Transform Remove Duplicates (Dedup)
  189. Remove Fields Transform Exclude Fields
  190. Remove/Retain Duplicate Fields Transform Remove Duplicates (Dedup)
  191. Rename Fields Quickly in Flat And Tabular Data Version 8.1.0 Fast Transform Rename Field Tabular Data Performance Flat Data
  192. Rename a Field Transform Rename Field
  193. Save and Load DataMapping to XML DataPipeline Foundations XML Data Mapping
  194. Save and Load DecisionTable to XML DataPipeline Foundations XML Decision Table
  195. Save and Load DecisionTree to XML DataPipeline Foundations XML Decision Tree
  196. Save and Restore Pipeline from JSON DataPipeline Foundations Pipeline
  197. Search Followers of a Twitter User Using v2 API Twitter2 STDOUT
  198. Search Twitter for Tweets Copy Field MS Excel Transform STDOUT Multi-writer Twitter
  199. Search Twitter for Tweets Using v2 API Twitter2 STDOUT
  200. Search for Jira Issues by Multiple IDs Jira
  201. Search for a Record Expression Language In-Memory Filter Search
  202. Select and Arrange Fields Include Fields Transform
  203. Serialize DataMapping containing special characters to XML DataPipeline Foundations XML Data Mapping Serialization
  204. Serialize and Deserialize Data Native CSV STDOUT Serialization
  205. Serialize and Deserialize Records STDOUT Serialization
  206. Set Default Values for Missing Data DataPipeline Foundations Schema
  207. Set a Calculated Field Programmatically Transform Calculated Field Assign Field
  208. Set a Calculated Field at Runtime Transform Expression Language Calculated Field Assign Field
  209. Set a Field Transform Assign Field
  210. Show Column Statistics DataPipeline Foundations Analyze Data Pipeline Dataset
  211. Show Data Mapping Model Problems DataPipeline Foundations Data Mapping
  212. Show Schema Model Problems DataPipeline Foundations Schema
  213. Show Unique Values in Column DataPipeline Foundations Analyze Data Pipeline
  214. Show the Columns and Tables of a Schema DataPipeline Foundations JDBC
  215. Skip First Line Using Limit Reader CSV
  216. Sort Records Transform Sort
  217. Specify Lookup Values Programmatically Lookup Transform
  218. Store Dataset In Memory DataPipeline Foundations Dataset
  219. Store Dataset on Disk DataPipeline Foundations Dataset
  220. Throttle Data being Read Throttle
  221. Throttle Data being Written Throttle
  222. Transform Records using Schema DataPipeline Foundations Schema
  223. Transition Jira Issue Jira
  224. Update Jira Issue Jira
  225. Upsert Records With Multiple JDBC Connections Version 8.1.0 Upsert JDBC Multi-Writer JDBC
  226. Upsert Records to MySql or MariaDB MySQL Upsert JDBC
  227. Upsert Records to Oracle Oracle Database Upsert JDBC
  228. Upsert Records to PostgreSql Upsert JDBC PostgreSQL
  229. Upsert Records to Sybase Microsoft SQL Server Upsert JDBC Sybase
  230. Upsert Records to a Database Using Insert and Update Upsert JDBC
  231. Upsert Records to a Database Using Merge Upsert JDBC
  232. Upsert Variable Field Records Upsert JDBC
  233. Use Data Lineage with CsvReader Debug Data Lineage CSV
  234. Use Data Lineage with ExcelReader MS Excel Debug Data Lineage
  235. Use Data Lineage with FixedWidthReader Debug Data Lineage Fixed Width
  236. Use Data Lineage with JdbcReader Debug Data Lineage JDBC
  237. Use Data Lineage with Lookup Lookup Debug Data Lineage
  238. Use Data Lineage with OrcReader Debug Data Lineage ORC
  239. Use Data Lineage with ParquetReader Parquet Debug Data Lineage
  240. Use Multi Threading in a Single Job Threading
  241. Use SchemaFilter to Validate Records in a Pipeline DataPipeline Foundations Schema
  242. Use Streaming Excel for Reading MS Excel
  243. Use Streaming Excel for Writing MS Excel CSV
  244. Use a Custom AWS S3 Endpoint with AmazonS3FileSystem Version 8.2.0 Amazon S3
  245. Use a Retrying Reader Retrying Avro
  246. Use a Retrying Writer Retrying Avro
  247. Use an EventBus DataPipeline Foundations EventBus
  248. Use an EventBus in a Pipeline EventBus Threading
  249. Validate Data using Entity Inheritance DataPipeline Foundations Validate Schema
  250. Validate Data using Nested Entities DataPipeline Foundations Validate Schema
  251. Validate Incoming Data Rules Transform Validate Expression Language
  252. Validate Record Fields DataPipeline Foundations Schema
  253. Validate Records using Fields and Rules DataPipeline Foundations Schema
  254. Validate Records using Rules DataPipeline Foundations Schema
  255. Validate Root Record Using Schema Validate Filter Schema
  256. Validate a Field DataPipeline Foundations Schema
  257. Validate a Value DataPipeline Foundations Schema
  258. Write A Parquet File Containing Spaces And Symbols In Column Names Parquet Transform CSV
  259. Write A Parquet File Using Database Table Schema Version 8.1.0 Parquet Database JDBC
  260. Write An ORC file to Amazon S3 using a Temporary File Amazon S3 ORC
  261. Write An Orc file to Amazon S3 Amazon S3 ORC
  262. Write Arrays and Nested Records to XML using FreeMarker Templates XML Freemarker XPath In-Memory Template
  263. Write CSV To XML Using FreeMarker Templates XML CSV Template
  264. Write Concatenated JSON
  265. Write Concatenated JSON With Nested Data Streaming data JSON
  266. Write Database View To Parquet File Version 8.1.0 Parquet Database JDBC
  267. Write Excel to Amazon S3 MS Excel Amazon S3
  268. Write HTML using FreeMarker Templates HTML In-Memory Template
  269. Write JSON Lines JSON Lines In-Memory JSON
  270. Write JSON Lines With Nested Data JSON Lines JSON
  271. Write Key-Value Fields to MapWriter In-Memory
  272. Write Parquet to Amazon S3 Parquet Amazon S3
  273. Write Parquet to Amazon S3 Using a Temporary File Parquet Amazon S3
  274. Write a CSV File to Database (1) CSV JDBC
  275. Write a CSV File to Database (2) CSV JDBC
  276. Write a CSV File to a Fixed Width / Fixed Length Record File CSV Fixed Width
  277. Write a Parquet File Parquet
  278. Write a Parquet file using Schema Parquet
  279. Write a Parquet file using schema from EntityDef Parquet Schema
  280. Write a Parquet file using the schema derived from any dataset Parquet
  281. Write a Parquet file using the schema from a database query Version 8.1.0 Parquet JDBC
  282. Write a Sequence of Files by Elapsed Time Simple CSV
  283. Write a Sequence of Files by Record Count Simple CSV
  284. Write a Simple JSON File Simple JSON
  285. Write a Simple XML File XML Simple
  286. Write an Avro File Avro
  287. Write an Orc File ORC
  288. Write an XML File Programmatically XML In-Memory Template
  289. Write an XML File using FreeMarker Templates XML Freemarker XPath In-Memory Template
  290. Write my own Data Reader Customize
  291. Write my own Data Writer Customize
  292. Write my own Filter or Validator Customize Transform Validate Filter
  293. Write my own Lookup Customize Lookup Transform
  294. Write my own Transformer Customize Transform
  295. Write to A Data Writer using Tee Reader STDOUT Multi-writer
  296. Write to Amazon S3 Using Multipart Streaming Amazon S3
  297. Write to Excel MS Excel CSV
  298. Write to JMS Queue JMS In-Memory
  299. Write to JMS Topic JMS In-Memory
  300. Write to JSON Stream (Simple) Simple In-Memory JSON
  301. Write to JSON Stream Programmatically In-Memory Template JSON
  302. Write to Memory CSV In-Memory
  303. Write to MongoDB CSV MongoDB
  304. Write to Several Data Writers at Once MS Excel In-Memory Multi-writer
  305. Write to XML Stream (Simple) XML Simple In-Memory
  306. Write to a Database Using Custom Jdbc Insert Strategy JDBC Insert Strategy JDBC
  307. Write to a Database Using Generic Upsert Strategy Upsert JDBC
  308. Write to a Database Using Merge Upsert Strategy Upsert JDBC
  309. Write to a Database Using Merge Upsert Strategy with Batch Upsert JDBC
  310. Write to a Database Using Multi Row Prepared Statement Insert Strategy JDBC Insert Strategy JDBC
  311. Write to a Database Using Multi Row Statement Insert Strategy JDBC Insert Strategy JDBC
  312. Write to a Database Using Multiple Connections MS Excel JDBC Multi-Writer JDBC
  313. Write to the Console STDOUT

All Examples

Mobile Analytics