[Task]: add samples for all transforms to the samples project

[bamaer]

What needs to happen?

there are no samples for the following transforms:

• [x] Add constants
• [x] Add value fields changing sequence
• [x] Add XML
• [x] Apache Tika
• [x] Avro Decode
• [x] Avro Encode
• [x] Avro File Input
• [x] Avro File Output
• [ ] Azure Event Hubs Listener
• [ ] Azure Event Hubs Writer
• [ ] Beam Bigtable Input
• [ ] Beam Bigtable Output
• [ ] Beam BigQuery Input
• [ ] Beam BigQuery Output
• [ ] Beam GCP Pub/Sub : Publish
• [ ] Beam GCP Pub/Sub : Subscribe
• [ ] Beam Input
• [ ] Beam Kafka Consume
• [ ] Beam Kafka Produce
• [ ] Beam Kinesis Consume
• [ ] Beam Kinesis Produce
• [ ] Beam Output
• [ ] Beam Timestamp
• [ ] Beam Window
• [ ] Cassandra Input
• [ ] Cassandra Output
• [ ] Cassandra SSTable Output
• [ ] Call DB procedure
• [ ] Change file encoding
• [x] Check if file is locked
• [x] Check if webservice is available
• [ ] Combination lookup/update
• [x] Concat Fields
• [x] Copy rows to result
• [x] Credit card validator
• [ ] Data Grid
• [ ] Delete
• [ ] De-Serialize From File
• [x] Detect Empty Stream
• [ ] Doris Bulk Loader
• [ ] Drools Rule Accumulator
• [ ] Drools Rule Executor
• [ ] Dummy (do nothing)
• [x] Dynamic SQL row
• [ ] Edi to XML
• [ ] Email Messages Input
• [ ] Enhanced JSON Output
• [ ] Excel input
• [ ] Excel writer
• [ ] Execute a process
• [ ] Execute row SQL script
• [ ] Execute SQL script
• [ ] Execute Unit Tests
• [ ] File exists
• [ ] File Metadata
• [ ] Files from result
• [ ] Files to result
• [ ] Generate Random Value
• [ ] Get Data From XML
• [ ] Get files rowcount
• [ ] Get records from stream
• [x] Get Rows from Result
• [ ] Get SubFolder names
• [ ] Get table names
• [ ] Get variables
• [ ] HTTP client
• [ ] HTTP Post
• [ ] Injector
• [ ] Join Rows
• [ ] JSON Input
• [ ] LDAP Input
• [ ] LDAP Output
• [ ] Load file content in memory
• [ ] Mail
• [ ] Mapping Input
• [ ] Mapping Output
• [ ] Memory Group By
• [ ] Merge rows (diff)
• [ ] Metadata Input
• [ ] Metadata structure of stream
• [ ] Microsoft Access Output
• [ ] MonetDB Bulk Loader
• [ ] MongoDB Input
• [ ] MongoDB Output
• [ ] Multiway Merge Join
• [ ] (Neo4j -> check for completeness)
• [ ] Oracle Bulk Loader
• [ ] Parquet File Input
• [ ] Parquet File Output
• [ ] Pipeline Data Probe
• [ ] PGP decrypt stream
• [ ] PGP encrypt stream
• [x] Pipeline Executor
• [ ] PostgreSQL Bulk Loader
• [ ] Process files
• [ ] Properties file Input
• [ ] Properties file Output
• [ ] Regex Evaluation
• [ ] Replace in String
• [ ] Reservoir Sampling
• [ ] REST Client
• [ ] Row Denormaliser
• [ ] Row Flattener
• [ ] Row Generator
• [ ] Row Normaliser
• [ ] Run SSH commands
• [ ] Salesforce Delete
• [ ] Salesforce Input
• [ ] Salesforce Insert
• [ ] Salesforce Update
• [ ] Salesforce Upsert
• [ ] Sample Rows
• [ ] SAS Input
• [ ] Serialize To File
• [ ] Server Status
• [ ] Set field value to a constant
• [ ] Set field Value to a field
• [ ] Set Variables
• [ ] Snowflake Bulk Loader
• [ ] Split fields to rows
• [ ] Splunk Input
• [ ] SQL File Output
• [ ] Stream Schema Merge
• [ ] String cut
• [ ] Synchronize after merge
• [ ] Table Compare
• [ ] Table Exists
• [ ] Teradata Bulk Loader
• [ ] Token Replacement
• [ ] Unique Rows (HashSet)
• [ ] Update
• [ ] User Defined Java Expression
• [ ] Web services lookup
• [ ] Workflow Executor
• [ ] Write to log
• [ ] XML Input Stream (StAX)
• [ ] XML Join
• [ ] XML Output
• [ ] XSD Validator
• [ ] XSL Transformation
• [ ] Yaml Input

Issue Priority

Priority: 3

Issue Component

Component: Samples

[campen]

MongoDB Input/output samples (zipped up) mongodb.zip Also I used this docker-compose file to spin up a mongo container: version: '3.1' services: mongo: image: mongo:latest ports:

• 27017:27017 environment: MONGO_INITDB_ROOT_USERNAME: root MONGO_INITDB_ROOT_PASSWORD: password