Describes how to ingest data from PostgreSQL table to RisingWave using table-valued function.
RisingWave allows you to query PostgreSQL tables directly with the postgres_query
table-valued function (TVF). It offers a simpler alternative to Change Data Capture (CDC) when working with PostgreSQL data in RisingWave.
Unlike CDC, which continuously syncs data changes, this function lets you fetch data directly from PostgreSQL when needed. Therefore, this approach is ideal static or infrequently updated data, as it’s more resource-efficient than maintaining a constant CDC connection.
PUBLIC PREVIEW
This feature is currently in public preview, meaning it is nearing the final product but may not yet be fully stable. If you encounter any issues or have feedback, please reach out to us via our Slack channel. Your input is valuable in helping us improve this feature. For more details, see our Public Preview Feature List.
Define postgres_query
as follows:
postgres_query
function to retrieve rows where id > 90
.Describes how to ingest data from PostgreSQL table to RisingWave using table-valued function.
RisingWave allows you to query PostgreSQL tables directly with the postgres_query
table-valued function (TVF). It offers a simpler alternative to Change Data Capture (CDC) when working with PostgreSQL data in RisingWave.
Unlike CDC, which continuously syncs data changes, this function lets you fetch data directly from PostgreSQL when needed. Therefore, this approach is ideal static or infrequently updated data, as it’s more resource-efficient than maintaining a constant CDC connection.
PUBLIC PREVIEW
This feature is currently in public preview, meaning it is nearing the final product but may not yet be fully stable. If you encounter any issues or have feedback, please reach out to us via our Slack channel. Your input is valuable in helping us improve this feature. For more details, see our Public Preview Feature List.
Define postgres_query
as follows:
postgres_query
function to retrieve rows where id > 90
.