ListTableNames 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
Description¶
Fetches all source table names and matches them with one of the possible configurations:
Regexp expression. Example: “(?i)customer.(orders|payments)”
This matches names without considering case, so both “CUSTOMER.ORDERS” and “customer.orders” are matched. Microsoft SQL Server also accepts fully qualified names, for example: (?i)prod.customer.(orders|payments).
Comma-separated list of source table names, for example: “customer.orders, customer.payments”.
This matches source table names in a case-sensitive way; for example, “customer.orders” will match, but “customer.ORDERS” will not. Microsoft SQL Server also accepts fully qualified names, such as “prod1.customer.orders, prod1.customer.payments”.
Configuration is passed as a FlowFile attribute. The source table name is represented as <schema_name>.<table_name>. Both inputs should take that into consideration.
Matched source table names are forwarded to MATCHED relationship. Processor generates a single flow file with matching tables.
Considerations¶
In PostgreSQL, database object names can be case sensitive or case insensitive. If you create a table with ‘CREATE TABLE ORDERS(id int not null)’, PostgreSQL stores the name in lowercase as orders.
To enforce case sensitivity, wrap the table name in double quotes, for example: ‘CREATE TABLE “ORDERS”(id int not null)’.
Input Requirement¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
Properties¶
Property |
Description |
|---|---|
Connection Pool |
The Controller Service that is used to obtain a connection to the database. |
Included Comma Separated Source Table Names |
Provide a comma-separated list of tables to replicate, formatted as <schema_name>.<table_name> (for example: customer.orders, customer.payments). This list works together with the regular expression to find matches. |
Included Source Table Pattern |
Use a regular expression to specify which table names to replicate, for example: |
Relationships¶
Name |
Description |
|---|---|
failure |
If a FlowFile attribute cannot be read or is incorrect, it will be routed to this Relationship. |
matched |
Successfully created FlowFile, with a list of matching tables found in the source database. |
Writes attributes¶
Name |
Description |
|---|---|
source.database.version.major |
The major version of the source database. |