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

• Formula

• Generate Random Value

• Get filenames

• Get records from stream

• Get ID from slave server

• Get System Info

• Get variables

• HTTP client

• Identify last row in a stream

• Injector

• Java Filter

• Join Rows

• JSON Output

• Kafka Producer

• LDAP Output

• Mail

• Mapping Input

• Memory Group By

• Merge rows (diff)

• Metadata Input

• MonetDB Bulk Loader

• MongoDB Output

• Neo4j Cypher

• Neo4j Get Logging Info

• Neo4j Import

• Neo4j Split Graph

• Number range

• Parquet File Output

• PGP encrypt stream

• Process files

• Properties file Output

• Replace in String

• REST Client

• Row Flattener

• Row Normaliser

• Salesforce Delete

• Salesforce Insert

• Salesforce Upsert

• SAS Input

• Serialize To File

• Set field Value to a field

• Simple Mapping

• Sorted Merge

• Split fields to rows

• SQL File Output

• Stream Lookup

• String cut

• Switch / Case

• Table Compare

• Table Input

• Teradata Bulk Loader

• Text File Output

• Unique Rows

• Update

• User Defined Java Expression

• Web services lookup

• Write to log

• XML Join

• XSD Validator

• Yaml Input