Transform Plugins

• Abort

• Add Constants

• Add value fields changing sequence

• Analytic Query

• Append Streams

• Avro File Input

• Azure Event Hubs Writer

• Beam BigQuery Output

• Beam GCP Pub/Sub : Subscribe

• Beam Kafka Consume

• Beam Output

• Beam Window

• Blocking until transforms finish

• Cassandra Input

• Cassandra SSTable Output

• Change file encoding

• Check if webservice is available

• Closure

• Column exists

• Concat Fields

• Credit card validator

• Database Join

• Data Grid

• Delete

• Detect Empty Stream

• Dummy (do nothing)

• Edi to XML

• Enhanced JSON Output

• Excel writer

• Execute row SQL script

• Execute Unit Tests

• File Metadata

• Files to result

• Fuzzy match

• Get Data From XML

• Get files rowcount

• Get Rows from Result

• Get SubFolder names

• Get table names

• Group By

• HTTP Post

• If Null

• Insert / Update

• JavaScript

• JSON Input

• Kafka Consumer

• LDAP Input

• Load file content in memory

• Mail Validator

• Mapping Output

• Merge Join

• Metadata Injection

• Metadata structure of stream

• MongoDB Input

• Multiway Merge Join

• Neo4j Generate CSVs

• Neo4j Graph Output

• Neo4j Output

• Null If

• Parquet File Input

• PGP decrypt stream

• PostgreSQL Bulk Loader

• Properties file Input

• Regex Evaluation

• Reservoir Sampling

• Row Denormaliser

• Row Generator

• Run SSH commands

• Salesforce Input

• Salesforce Update

• Sample Rows

• Select Values

• Set field value to a constant

• Set Variables

• Sort Rows

• Split Fields

• Splunk Input

• Standardize Phone Number

• Stream Schema Merge

• String operations

• Synchronize after merge

• Table Exists

• Table Output

• Text File Input

• Token Replacement

• Unique Rows (HashSet)

• User Defined Java Class

• Value Mapper

• Workflow Executor

• XML Input Stream (StAX)

• XML Output

• XSL Transformation