Origins
The following table lists the data formats supported by each origin.
| Origin | Avro | Binary | Datagram | Delimited | Excel | JSON | Log | Protobuf | SDC Record | Text | Whole File | XML |
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Amazon S3 |  |
|
|
|
|
|
|
|
|
|
||
| Amazon SQS Consumer | |
|
|
|
|
|
|
|
|
|||
| Azure Data Lake Storage Gen1 | |
|
|
|
|
|
|
|
|
|
||
| Azure Data Lake Storage Gen2 | |
|
|
|
|
|
|
|
|
|
||
| Azure IoT/Event Hub Consumer | |
|
|
|
||||||||
| CoAP Server | |
|
|
|
|
|
|
|
|
|||
| Cron Scheduler | * * * Not Applicable * * * | |||||||||||
| Directory | |
|
|
|
|
|
|
|
|
|
||
| Elasticsearch | * * * Not Applicable * * * | |||||||||||
| File Tail | |
|
|
|||||||||
| Google BigQuery | * * * Not Applicable * * * | |||||||||||
| Google Cloud Storage | |
|
|
|
|
|
|
|
||||
| Google Pub/Sub Subscriber | |
|
|
|
|
|
|
|
||||
| Groovy Scripting | * * * Not Applicable * * * | |||||||||||
| gRPC Client | |
|
|
|||||||||
| Hadoop FS | |
|
|
|||||||||
| Hadoop FS Standalone | |
|
|
|
|
|
|
|
|
|
||
| HTTP Client | |
|
|
|
|
|
|
|||||
| HTTP Server | |
|
|
|
|
|
|
|
||||
| JavaScript Scripting | * * * Not Applicable * * * | |||||||||||
| JDBC Multitable Consumer | * * * Not Applicable * * * | |||||||||||
| JDBC Query Consumer | * * * Not Applicable * * * | |||||||||||
| JMS Consumer | |
|
|
|
|
|
|
|
|
|||
| Jython Scripting | * * * Not Applicable * * * | |||||||||||
| Kafka Consumer | |
|
|
|
|
|
|
|
|
|
||
| Kafka Multitopic Consumer | |
|
|
|
|
|
|
|
|
|
||
| Kinesis Consumer | |
|
|
|
|
|
|
|
|
|||
| MapR DB CDC | * * * Not Applicable * * * | |||||||||||
| MapR DB JSON | * * * Not Applicable * * * | |||||||||||
| MapR FS | |
|
|
|||||||||
| MapR FS Standalone | |
|
|
|
|
|
|
|
|
|
||
| MapR Multitopic Streams Consumer | |
|
|
|
|
|
|
|
|
|||
| MapR Streams Consumer | |
|
|
|
|
|
|
|
||||
| MongoDB | * * * Not Applicable * * * | |||||||||||
| MongoDB Oplog | * * * Not Applicable * * * | |||||||||||
| MQTT Subscriber | |
|
|
|
|
|
|
|
|
|||
| MySQL Binary Log | * * * Not Applicable * * * | |||||||||||
| NiFi HTTP Server |
|
|
|
|
|
|
|
|
|
|||
| Omniture | * * * Not Applicable * * * | |||||||||||
| OPC UA Client | * * * Not Applicable * * * | |||||||||||
| Oracle Bulkload | * * * Not Applicable * * * | |||||||||||
| Oracle CDC Client | * * * Not Applicable * * * | |||||||||||
| PostgreSQL CDC Client | * * * Not Applicable * * * | |||||||||||
| Pulsar Consumer | |
|
|
|
|
|
|
|
|
|||
| RabbitMQ Consumer | |
|
|
|
|
|
|
|
|
|||
| Redis Consumer | |
|
|
|
|
|
|
|
|
|||
| REST Service | |
|
|
|
|
|
|
|
||||
| Salesforce | * * * Not Applicable * * * | |||||||||||
| SAP HANA Query Consumer | * * * Not Applicable * * * | |||||||||||
| SDC RPC | |
|||||||||||
| SFTP/FTP/FTPS Client | |
|
|
|
|
|
|
|
|
|
||
| SQL Server 2019 BDC Multitable Consumer | * * * Not Applicable * * * | |||||||||||
| SQL Server CDC Client | * * * Not Applicable * * * | |||||||||||
| SQL Server Change Tracking | * * * Not Applicable * * * | |||||||||||
| Start Jobs | * * * Not Applicable * * * | |||||||||||
| Start Pipelines | * * * Not Applicable * * * | |||||||||||
| System Metrics | * * * Not Applicable * * * | |||||||||||
| TCP Server | |
|
|
|
|
|
|
|
|
|||
| Teradata Consumer | * * * Not Applicable * * * | |||||||||||
| UDP Multithreaded Source | * * * Not Applicable * * * | |||||||||||
| UDP Source | * * * Not Applicable * * * | |||||||||||
| WebSocket Client | |
|
|
|
|
|
|
|
|
|||
| WebSocket Server | |
|
|
|
|
|
|
|
|
|||
| Windows Event Log | * * * Not Applicable * * * | |||||||||||