Skip to content

Releases: risingwavelabs/dbt-risingwave

v1.9.4

10 Aug 12:38
5c9740d
Compare
Choose a tag to compare

v1.9.3

24 Jul 08:52
b628cc0
Compare
Choose a tag to compare
  • #70 feat: zero down time materialized view rebuilds

v1.9.2

07 Jun 06:05
9e1b5f8
Compare
Choose a tag to compare
  • #69 fix duplicated relation names

v1.9.1

11 Mar 14:06
30e8f94
Compare
Choose a tag to compare
  • #63 use delete statement instead of truncate for dbt seed.
  • #62 fix dropping primary index.

v1.9.0

11 Dec 09:32
0e98d00
Compare
Choose a tag to compare
  • use __get_index_name for dropping index too #57
  • bump dbt version to 1.9 #58

v1.8.1

08 Nov 05:27
Compare
Choose a tag to compare
  • add cancel method for streaming jobs #49
  • add create_indexes on table_with_connector and handle on_configuration_change #51
  • add sql_header support #52

v1.8.0

09 Aug 06:12
88bd89b
Compare
Choose a tag to compare
  • Bump dbt-core to 1.8.0

v1.7.4

07 May 03:31
f58af57
Compare
Choose a tag to compare
  • Support emit on window close syntax for the materialized view model.

v1.7.3

15 Mar 06:32
Compare
Choose a tag to compare
  • Support rename statement in dbt-risingwave.
  • Fix incremental model, dbt run with --full-refresh.

v1.7.2

13 Mar 05:20
Compare
Choose a tag to compare
  • Support incremental model. You can use incremental when you want to have better control of when the table should be updated in a batch way.
  • Improve sink model, now we can define sink in this way
{{
    config(
        materialized="sink",
        connector="kinesis",
        data_format="PLAIN",
        data_encode="JSON",
        connector_parameters={
            "primary_key": "pk,sk",
            "stream": var("kinesis_sink")[target.profile_name]["stream"],
            "aws.region": var("kinesis_sink")[target.profile_name]["region"],
            "aws.credentials.role.arn": var("kinesis_sink")[target.profile_name]["role_arn"],
            "aws.credentials.access_key_id": env_var('AWS_ACCESS_KEY_ID', ''),
            "aws.credentials.secret_access_key": env_var("AWS_SECRET_ACCESS_KEY", ''),

        },
        format_parameters={
            "force_append_only": true,
        },
    )
}}

-- do some wrangling here:
SELECT * FROM {{ ref("model1") }}