AwsGlueSchemaRegistry | AWS Glue schema registry attached to a KafkaStreamSrcConn. |
AzureBlobSrc | Azure Blob source for @publisher -- one output slot per path. |
AzureBlobSrcConn | Azure Blob connection used by AzureBlobSrc. |
BinlogPosition | CDC start position: a binlog file + byte offset. |
CommitSeqPosition | CDC start position: one global commit sequence for every table. |
ConfluentSchemaRegistry | Confluent-style schema registry attached to a KafkaStreamSrcConn. |
Data | One dataframe emitted by DataGenSrc, optionally chunked. |
DatabricksSrc | Databricks source for @publisher -- one output slot per query. |
DatabricksSrcConn | Databricks workspace connection used by DatabricksSrc. |
DataGenSrc | Source emitting in-line dataframes for @publisher -- one slot per Data. |
DataGenSrcConn | Connection for DataGenSrc -- no configuration. |
Db2CdcStreamSrc | Db2 CDC stream source for @stream_publisher. |
Db2CdcStreamSrcConn | Db2 CDC connection used by Db2CdcStreamSrc. |
Db2Src | Db2 source for @publisher -- one output slot per query. |
Db2SrcConn | Db2 connection used by Db2Src. |
GCSSrc | GCS source for @publisher -- one output slot per path. |
GCSSrcConn | GCS connection used by GCSSrc. |
GtidPosition | CDC start position: a MySQL Global Transaction ID. |
KafkaStreamSrc | Kafka streaming source for @stream_publisher -- one batch per rollover. |
KafkaStreamSrcConn | Kafka connection used by KafkaStreamSrc. |
LocalFileSrc | LocalFile source for @publisher -- one output slot per path. |
LocalFileSrcConn | LocalFile connection used by LocalFileSrc. |
LsnPosition | CDC start position: a WAL Log Sequence Number. |
ManifestStageConn | Connection for ManifestStageSrc -- one stage backend. |
ManifestStageSrc | Stream-stage source -- materialises the files in one manifest. |
MSSQLSrc | MSSQL source for @publisher -- one output slot per query. |
MSSQLSrcConn | MSSQL connection used by MSSQLSrc. |
MySQLCdcStreamSrc | MySQL CDC stream source for @stream_publisher. |
MySQLCdcStreamSrcConn | MySQL CDC connection used by MySQLCdcStreamSrc. |
MySQLSrc | MySQL source for @publisher -- one output slot per query. |
MySQLSrcConn | MySQL connection used by MySQLSrc. |
OracleSrc | Oracle source for @publisher -- one output slot per query. |
OracleSrcConn | Oracle connection used by OracleSrc. |
PostgresCdcStreamSrc | Postgres CDC stream source for @stream_publisher. |
PostgresCdcStreamSrcConn | Postgres CDC connection used by PostgresCdcStreamSrc. |
PostgresSrc | Postgres source for @publisher -- one output slot per query. |
PostgresSrcConn | Postgres connection used by PostgresSrc. |
S3Src | S3 source for @publisher -- one output slot per path. |
S3SrcConn | S3 connection used by S3Src. |
SalesforceReportSrc | Salesforce report source for @publisher -- Tabular reports only. |
SalesforceSrc | Salesforce SOQL source for @publisher -- one query. |
SalesforceSrcConn | Salesforce org connection used by SalesforceSrc / SalesforceReportSrc. |
Src | Abstract batch source. |
StreamSrc | Abstract stream source. |
TableCommitSeqPosition | CDC start position: independent commit sequence per table. |
TimestampPosition | CDC start position given as a wall-clock timestamp. |
TimestampPosition | CDC start position given as a wall-clock timestamp. |