All Examples
- Add Array Fields to Entities DataPipeline Foundations Schema
- Add Attributes and Tags to Schemas DataPipeline Foundations Schema
- Add Calculated Fields to a Decision Table DataPipeline Foundations Decision Table Calculated Field
- Add Calculated Fields to a Decision Tree DataPipeline Foundations Calculated Field Decision Tree
- Add Indexes to Entities DataPipeline Foundations Schema
- Add Jira Comments Jira
- Add Nested Entities as Fields DataPipeline Foundations Schema
- Add Non-Persistent Data to Records and Fields In-Memory Out-of-band data
- Add Primary Keys to Entities DataPipeline Foundations Schema
- Add Relationship Between Entities DataPipeline Foundations Schema
- Add a Decision Table to a Pipeline DataPipeline Foundations Decision Table
- Add a Decision Tree to a Pipeline DataPipeline Foundations Decision Tree
- Add a Sequence Number Column Transform Calculated Field Assign Field
- Add a Sequence Number Column for Repeat Values Transform Calculated Field Assign Field
- Add a Sequence Number Column when Values Change Transform Calculated Field Assign Field
- Add my own Functions Customize Expression Language Assign Field Functions
- Automatically Map Data And Exclude Fields Declaratively Version 8.1.0 DataPipeline Foundations XML Declarative Data Mapping
- Blacklist and Whitelist Functions in DP Expression Language Customize Expression Language Functions
- Buffer Records by Time Period or Count Streaming data
- Build DataMappingPipeline Declaratively from Json DataPipeline Foundations Declarative Data Mapping JSON
- Build DataMappingPipeline Declaratively from XML DataPipeline Foundations XML Declarative Data Mapping
- Build DataMappingPipeline Programmatically DataPipeline Foundations Data Mapping
- Cache Lookup Values Lookup Transform JDBC Cache
- Capture Data Not Joined in a Lookup Lookup
- Capture Data that Failed Data Mapping Validation DataPipeline Foundations Data Mapping
- Compare Records Using Diff DataPipeline Foundations Diff
- Compare Schemas Using Diff DataPipeline Foundations Diff Schema
- Compile and Run a Job Job management CSV Fixed Width
- Compress a Parquet File Parquet
- Compress an Orc File ORC
- Conditionally Map Data Field from Source to Target DataPipeline Foundations Data Mapping
- Conditionally Transform Data Simple Transform Filter JSON Assign Field
- Conditionally Write to Multiple Files Transform Multi-writer Threading
- Conditionally map Data from Source to Target DataPipeline Foundations Data Mapping
- Configure AmazonS3FileSystem Using Client Amazon S3
- Configure the Insert Strategy used in JdbcMultiWriter Version 8.1.0 JDBC Multi-Writer JDBC Insert Strategy JDBC
- Continue After an Error Exceptions
- Convert JSON to CSV Simple CSV Conversion JSON
- Convert JSON to Parquet Parquet Conversion JSON
- Convert Unstructured JSON to Parquet Parquet Conversion JSON
- Convert a Single Source DataReader into Many XML Simple Conversion Avro Threading JSON
- Copy a Field Copy Field Transform
- Create Custom Pipeline Action Customize DataPipeline Foundations Pipeline
- Create Custom Pipeline Input DataPipeline Foundations Pipeline
- Create Custom Pipeline Output DataPipeline Foundations Pipeline
- Create Jira Issue Jira
- Create a JsonPipelineInput Declaratively From Xml DataPipeline Foundations XML Declarative Pipeline
- Create a JsonPipelineInput Declaratively from JSON DataPipeline Foundations Declarative Pipeline JSON
- Create a JsonPipelineInput Programmatically DataPipeline Foundations Pipeline
- Create an XmlPipelineInput Declaratively From Xml DataPipeline Foundations XML Declarative Pipeline
- Create an XmlPipelineInput Declaratively from Json DataPipeline Foundations Declarative Pipeline JSON
- Create an XmlPipelineInput Programmatically DataPipeline Foundations Pipeline
- Debug my Code Debug
- Declaratively Map Data DataPipeline Foundations Declarative Data Mapping
- Declaratively Map Data Using Positions DataPipeline Foundations Declarative Data Mapping
- Declaratively Map Data with Source and Target Schema DataPipeline Foundations Declarative Data Mapping Schema
- Declaratively Map XML Files DataPipeline Foundations XML Declarative Data Mapping
- Declaratively Set Default Values for Missing Data DataPipeline Foundations Declarative Schema
- Declaratively Transform Records using Schema DataPipeline Foundations Declarative Schema
- Delete Jira Issue Jira
- Detect Date and Time Patterns in Strings DataPipeline Foundations Analyze Data
- Detect Numbers in Strings DataPipeline Foundations Analyze Data
- Detect Primary Keys In a Dataset DataPipeline Foundations Schema Dataset
- Evaluate a Decision Table DataPipeline Foundations Decision Table
- Evaluate a Decision Table with Lookup DataPipeline Foundations Lookup Decision Table
- Evaluate a Decision Tree DataPipeline Foundations Decision Tree
- Evaluate a Decision Tree with Lookup DataPipeline Foundations Lookup Decision Tree
- Execute an Action in a Decision Table DataPipeline Foundations Decision Table
- Execute an Action in a Decision Tree DataPipeline Foundations Decision Tree
- Extract Bigrams, Trigrams, and Ngrams XML Transform Analyze Data
- Filter Columns with All Null Values DataPipeline Foundations Pipeline
- Filter Json Records in a Pipeline DataPipeline Foundations Pipeline Filter
- Filter Json Records in a Pipeline Declaratively from Json DataPipeline Foundations Declarative Pipeline Filter JSON
- Filter Json Records in a Pipeline Declaratively from Xml DataPipeline Foundations XML Declarative Pipeline Filter
- Filter Records Rules Transform Expression Language Filter
- Filter Twitter in Real Time Streaming data Filter Twitter
- Filter Twitter in Real Time Using v2 API Twitter2 Streaming data Filter
- Find The Minimum Maximum Average Sum Count Stats Transform CSV Conversion Aggregate STDOUT
- Generate Java Beans from a Database DataPipeline Foundations JDBC Code Generation
- Generate MySQL DDL Programmatically MySQL Code Generation
- Generate MySQL INSERT Statements Programmatically MySQL Database Code Generation
- Generate MySql DDL From CSV MySQL DataPipeline Foundations CSV Code Generation Schema
- Generate MySql INSERT Statements From CSV MySQL CSV Database Code Generation
- Generate Parquet Schema By Analyzing All Records Parquet CSV
- Generate Parquet Schema By Analyzing Initial Records Parquet CSV
- Generate PostgreSQL DDL From Excel DataPipeline Foundations MS Excel PostgreSQL Code Generation Schema
- Generate PostgreSQL DDL Programmatically PostgreSQL Code Generation
- Generate PostgreSql DDL From CSV DataPipeline Foundations CSV PostgreSQL Code Generation Schema
- Generate SQL Queries Programmatically MySQL Microsoft SQL Server JDBC PostgreSQL
- Generate Schema From JDBC DataPipeline Foundations JDBC Schema
- Generate Schema Java Code DataPipeline Foundations Code Generation Schema
- Generate Union and Sub-Select SQL Queries Programmatically MySQL Microsoft SQL Server JDBC PostgreSQL
- Generate a PDF XML Simple PDF
- Generate a Word Document Simple RTF JSON
- Generate toRecord And fromRecord Using The GenerateRecordSerializers Tool Code Generation Serialization
- Get a Query Param from a URL Transform Assign Field
- Group Records by TimePeriod or Count Aggregate
- Handle Exceptions Exceptions
- Handle Filtered Records Transform Fixed Width Filter Calculated Field Assign Field
- Handle Transforming Reader Failures Exceptions XML Transform Rename Field Filter
- Handle Transforming Writer Failures Exceptions Transform Conversion Fixed Width Filter Calculated Field
- Handle Validation Failures XML Validate Filter
- How To Read An XML File With A Byte Order Mark (BOM) XML
- How to Convert Tabular Data to Trees Using Aggregation Transform CSV Sort
- Infer Date Time from a CSV File DataPipeline Foundations Analyze Data Pipeline Dataset
- Insert Multiple Rows to Oracle Using Insert All Oracle Database Version 8.1.0 JDBC Insert Strategy JDBC
- Insert Multiple Rows to Oracle Using Select Union Oracle Database Version 8.1.0 JDBC Insert Strategy JDBC
- Join CSV Files CSV
- Load Snapshot of Dataset DataPipeline Foundations Pipeline
- Log Diagnostic Information Debug
- Log Job Progress Job management STDOUT
- Look Up Jira Transition IDs Jira
- Lookup Data in a Database Lookup Transform JDBC
- Lookup Data in any Data Reader Lookup Transform
- Lookup in a Flat File Lookup Transform
- Manipulate Fields Transform Conversion In-Memory
- Map Data Using Automatic Mapping And Exclude Fields Version 8.1.0 DataPipeline Foundations CSV Data Mapping
- Map Data from Source to Target DataPipeline Foundations Data Mapping
- Map Data from Source to Target in a Pipeline DataPipeline Foundations Data Mapping
- Map Data from Source to Target in a Pipeline with Validation DataPipeline Foundations Data Mapping
- Map Data from Source to Target with Lookup DataPipeline Foundations Data Mapping
- Map Data with Rule Based Validation DataPipeline Foundations Data Mapping
- Map Data with Schema Based Validation DataPipeline Foundations Data Mapping
- Map Records in Pipeline using Schema DataPipeline Foundations Pipeline Schema
- Map Records using Schema DataPipeline Foundations Schema
- Measure Data Lineage Performance Debug Data Lineage Performance
- Measure Data being Read and Written Meter
- Measure Performance of Reader and Writer Performance
- My Data Reader Customize
- My Data Writer Customize
- My Filter Customize Filter
- My Lookup Customize Lookup
- My Proxy Reader Customize Transform
- My Proxy Writer Customize Transform
- My Transformer Customize Transform
- Obtain Statistics Stats MS Excel Meter
- Open and Close Several Data Readers and Data Writers at Once JDBC
- Pipe a Writer to a Reader Pipe Push Threading
- Profile Performance Performance
- Read A CSV File using Multithreading CSV Threading
- Read An ORC file from Amazon S3 Amazon S3 ORC
- Read An ORC file from Amazon S3 using a Temporary File Amazon S3 ORC
- Read Big Decimal In JSON JSON
- Read BigDecimal and BigInteger from an Excel file MS Excel
- Read Concatenated JSON JSON
- Read Emails Email STDOUT
- Read Google Analytics Social Interactions Google
- Read Google Analytics goal conversions Google
- Read Google Analytics views Google
- Read Google Calendar Google
- Read Google Contacts Google
- Read Google Gmail Messages Email Google
- Read JSON Records From File JSON
- Read Jira Comments Jira
- Read Jira issues Jira
- Read Json Lines JSON Lines JSON
- Read Json Lines As Record JSON Lines JSON
- Read MailChimp Contacts MailChimp
- Read MailChimp Contacts Using the RESTful Client API MailChimp
- Read Parquet from Amazon S3 Parquet Amazon S3
- Read Parquet from Amazon S3 using a Temporary File Parquet Amazon S3
- Read Selected Fields from a Parquet File Parquet
- Read Selected Fields from an Orc File ORC
- Read Shopify Inventory Items E-commerce Shopify
- Read Shopify Inventory Levels E-commerce Shopify
- Read Shopify Orders E-commerce Shopify
- Read Shopify Store Locations E-commerce Shopify
- Read Trello Cards Trello
- Read Tweets from a User's Timeline Using v2 API Twitter2 STDOUT Twitter
- Read UUID from PostgreSQL Job management UUID JDBC PostgreSQL
- Read XML Records From File XML
- Read a Bloomberg Message File Bloomberg
- Read a CSV File CSV
- Read a Fixed-width File / Fixed-length Record File Fixed Width
- Read a JSON Stream Conversion XPath STDOUT JSON
- Read a Parquet File Parquet
- Read a Patient File Simple CSV
- Read a Set of Files CSV Batch
- Read a Simple JSON File Simple JSON
- Read a Simple XML File XML Simple
- Read a Tab Separated Values File CSV
- Read a Web Server Log Web Server Logs STDOUT
- Read an Avro File Avro
- Read an Orc File ORC
- Read an XML File XML XPath
- Read an XML File (2) XML Transform Conversion XPath JDBC
- Read and Transform Data in Parallel Transform Threading
- Read and Write CSV as String CSV
- Read and Write Kafka Events Kafka
- Read and Write Unsigned Numbers in Parquet Files Version 8.1.0 Parquet
- Read and Write to an EventBus EventBus Threading
- Read from Amazon S3 Amazon S3
- Read from CSV And Writer to Excel DataPipeline Foundations Pipeline
- Read from Gmail Email STDOUT
- Read from JMS Queue JMS In-Memory
- Read from JMS Topic JMS In-Memory
- Read from Java beans XPath Java Beans
- Read from Memory CSV In-Memory
- Read from MongoDB CSV STDOUT MongoDB
- Read from a Database JDBC
- Read from an Excel File MS Excel
- Read from database using OPINIONATED type mapping JDBC
- Read from database using ORIGINAL type mapping JDBC
- Read from database using STRICT type mapping JDBC
- Read using TimedReader Performance
- Remove Duplicates Transform Remove Duplicates (Dedup)
- Remove Fields Transform Exclude Fields
- Remove/Retain Duplicate Fields Transform Remove Duplicates (Dedup)
- Rename Duplicate Fields Transform Rename Field
- Rename Fields Containing Spaces and Symbols Transform Rename Field
- Rename Fields Quickly in Flat And Tabular Data Version 8.1.0 Fast Transform Rename Field Tabular Data Performance Flat Data
- Rename a Field Transform Rename Field
- Save and Load DataMapping to XML DataPipeline Foundations XML Data Mapping
- Save and Load DecisionTable to XML DataPipeline Foundations XML Decision Table
- Save and Load DecisionTree to XML DataPipeline Foundations XML Decision Tree
- Save and Load Diff to Record DataPipeline Foundations Diff Dataset
- Save and Restore Pipeline from JSON DataPipeline Foundations Pipeline
- Search Followers of a Twitter User Using v2 API Twitter2 STDOUT
- Search Twitter for Tweets Copy Field MS Excel Transform STDOUT Multi-writer Twitter
- Search Twitter for Tweets Using v2 API Twitter2 STDOUT
- Search for Jira Issues by Multiple IDs Jira
- Search for a Record Expression Language In-Memory Filter Search
- Select and Arrange Fields Include Fields Transform
- Serialize DataMapping containing special characters to XML DataPipeline Foundations XML Data Mapping Serialization
- Serialize RecordList to and from JSON JSON Serialization
- Serialize RecordList to and from XML XML Serialization Dataset
- Serialize and Deserialize Data Native CSV STDOUT Serialization
- Serialize and Deserialize Records STDOUT Serialization
- Set Default Values for Missing Data DataPipeline Foundations Schema
- Set a Calculated Field Programmatically Transform Calculated Field Assign Field
- Set a Calculated Field at Runtime Transform Expression Language Calculated Field Assign Field
- Set a Field Transform Assign Field
- Show Column Statistics DataPipeline Foundations Analyze Data Pipeline Dataset
- Show Data Mapping Model Problems DataPipeline Foundations Data Mapping
- Show Schema Model Problems DataPipeline Foundations Schema
- Show Unique Values in Column DataPipeline Foundations Analyze Data Pipeline
- Show the Columns and Tables of a Schema DataPipeline Foundations JDBC
- Skip First Line Using Limit Reader CSV
- Sort Records Transform Sort
- Specify Lookup Values Programmatically Lookup Transform
- Store Dataset In Memory DataPipeline Foundations Dataset
- Store Dataset on Disk DataPipeline Foundations Dataset
- Stream Record Fields Java Streams Streaming data
- Throttle Data being Read Throttle
- Throttle Data being Written Throttle
- Transform Records using Schema DataPipeline Foundations Schema
- Transition Jira Issue Jira
- Update Jira Issue Jira
- Upsert Records With Multiple JDBC Connections Version 8.1.0 Upsert JDBC Multi-Writer JDBC
- Upsert Records to MySql or MariaDB MySQL Upsert JDBC
- Upsert Records to Oracle Oracle Database Upsert JDBC
- Upsert Records to PostgreSql Upsert JDBC PostgreSQL
- Upsert Records to Sybase Microsoft SQL Server Upsert JDBC Sybase
- Upsert Records to a Database Using Insert and Update Upsert JDBC
- Upsert Records to a Database Using Merge Upsert JDBC
- Upsert Variable Field Records Upsert JDBC
- Use Data Lineage with CsvReader Debug Data Lineage CSV
- Use Data Lineage with ExcelReader MS Excel Debug Data Lineage
- Use Data Lineage with FixedWidthReader Debug Data Lineage Fixed Width
- Use Data Lineage with JdbcReader Debug Data Lineage JDBC
- Use Data Lineage with Lookup Lookup Debug Data Lineage
- Use Data Lineage with OrcReader Debug Data Lineage ORC
- Use Data Lineage with ParquetReader Parquet Debug Data Lineage
- Use Multi Threading in a Single Job Threading
- Use SchemaFilter to Validate Records in a Pipeline DataPipeline Foundations Schema
- Use Streaming Excel for Reading MS Excel
- Use Streaming Excel for Writing MS Excel CSV
- Use a Custom AWS S3 Endpoint with AmazonS3FileSystem Version 8.2.0 Amazon S3
- Use a Retrying Reader Retrying Avro
- Use a Retrying Writer Retrying Avro
- Use an EventBus DataPipeline Foundations EventBus
- Use an EventBus in a Pipeline EventBus Threading
- Validate Data using Entity Inheritance DataPipeline Foundations Validate Schema
- Validate Data using Nested Entities DataPipeline Foundations Validate Schema
- Validate Incoming Data Rules Transform Validate Expression Language
- Validate Record Fields DataPipeline Foundations Schema
- Validate Records using Fields and Rules DataPipeline Foundations Schema
- Validate Records using Rules DataPipeline Foundations Schema
- Validate Root Record Using Schema Validate Filter Schema
- Validate a Field DataPipeline Foundations Schema
- Validate a Value DataPipeline Foundations Schema
- Write A Parquet File Containing Spaces And Symbols In Column Names Parquet Transform CSV
- Write A Parquet File Using Database Table Schema Version 8.1.0 Parquet Database JDBC
- Write An ORC file to Amazon S3 using a Temporary File Amazon S3 ORC
- Write An Orc file to Amazon S3 Amazon S3 ORC
- Write Arrays and Nested Records to XML using FreeMarker Templates XML Freemarker XPath In-Memory Template
- Write CSV To XML Using FreeMarker Templates XML CSV Template
- Write Concatenated JSON
- Write Concatenated JSON With Nested Data Streaming data JSON
- Write Database View To Parquet File Version 8.1.0 Parquet Database JDBC
- Write Excel to Amazon S3 MS Excel Amazon S3
- Write HTML using FreeMarker Templates HTML In-Memory Template
- Write JSON Lines JSON Lines In-Memory JSON
- Write JSON Lines With Nested Data JSON Lines JSON
- Write Key-Value Fields to MapWriter In-Memory
- Write Parquet to Amazon S3 Parquet Amazon S3
- Write Parquet to Amazon S3 Using a Temporary File Parquet Amazon S3
- Write UUID to JSON file UUID JSON
- Write a CSV File to Database (1) CSV JDBC
- Write a CSV File to Database (2) CSV JDBC
- Write a CSV File to a Fixed Width / Fixed Length Record File CSV Fixed Width
- Write a JSON File using FreeMarker Templates Freemarker XPath In-Memory Template JSON
- Write a Parquet File Parquet
- Write a Parquet file using Schema Parquet
- Write a Parquet file using schema from EntityDef Parquet Schema
- Write a Parquet file using the schema derived from any dataset Parquet
- Write a Parquet file using the schema from a database query Version 8.1.0 Parquet JDBC
- Write a Sequence of Files by Elapsed Time Simple CSV
- Write a Sequence of Files by Record Count Simple CSV
- Write a Simple JSON File Simple JSON
- Write a Simple XML File XML Simple
- Write an Avro File Avro
- Write an Orc File ORC
- Write an XML File Programmatically XML In-Memory Template
- Write an XML File using FreeMarker Templates XML Freemarker XPath In-Memory Template
- Write my own Data Reader Customize
- Write my own Data Writer Customize
- Write my own Filter or Validator Customize Transform Validate Filter
- Write my own Lookup Customize Lookup Transform
- Write my own Transformer Customize Transform
- Write to A Data Writer using Tee Reader STDOUT Multi-writer
- Write to Amazon S3 Using Multipart Streaming Amazon S3
- Write to Excel MS Excel CSV
- Write to JMS Queue JMS In-Memory
- Write to JMS Topic JMS In-Memory
- Write to JSON Stream (Simple) Simple In-Memory JSON
- Write to JSON Stream Programmatically In-Memory Template JSON
- Write to Memory CSV In-Memory
- Write to MongoDB CSV MongoDB
- Write to Several Data Writers at Once MS Excel In-Memory Multi-writer
- Write to XML Stream (Simple) XML Simple In-Memory
- Write to a Database Using Custom Jdbc Insert Strategy JDBC Insert Strategy JDBC
- Write to a Database Using Generic Upsert Strategy Upsert JDBC
- Write to a Database Using Merge Upsert Strategy Upsert JDBC
- Write to a Database Using Merge Upsert Strategy with Batch Upsert JDBC
- Write to a Database Using Multi Row Prepared Statement Insert Strategy JDBC Insert Strategy JDBC
- Write to a Database Using Multi Row Statement Insert Strategy JDBC Insert Strategy JDBC
- Write to a Database Using Multiple Connections MS Excel JDBC Multi-Writer JDBC
- Write to the Console STDOUT