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 for static or infrequently updated data, as it’s more resource-efficient than maintaining a constant CDC connection.
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 for static or infrequently updated data, as it’s more resource-efficient than maintaining a constant CDC connection.
Define postgres_query
as follows:
postgres_query
function to retrieve rows where id > 90
.