risingwavelabs/risingwave v1.0.0

on GitHub

For installation and running instructions, see Get started.

Main changes

SQL features

• SQL command:

  • Supports the SHOW CLUSTERS command. #10656

  • Supports the GROUPING SETS clause. #10807

• SQL function:

  • Adds the current_setting() function to get the current value of a configuration parameter. #10051

  • Adds new array functions: array_position(), array_replace(), array_ndims(), array_lower(), array_upper(), array_length(), and array_dims(). #10166, #10197

  • Adds new aggregate functions: percentile_cont(), percentile_disc(), and mode(). #10252

  • Adds new system functions: user(), current_user(), and current_role(). #10366

  • Adds new string functions: left() and right(). #10765

  • Adds new bytea functions: octet_length() and bit_length(). #10462

  • array_length() and cardinality() return integer instead of bigint. #10267

  • Supports the row_number window function that doesn't match the TopN pattern. #10869

• User-defined function:

  • Adds support for defining UDFs in Java. #10095

  • Adds support for more Java UDF and Python UDF data types. #10399

  • The language parameter is no longer required in CREATE FUNCTION. #10608

• System catalog:

  • Adds more columns to information_schema.columns: column_default, character_maximum_length, and udt_name. #10269

  • Adds a new system catalog pg_proc. #10216

  • Adds new RisingWave catalogs:

    • rw_table_fragments, rw_fragments, rw_actors #10712
    • rw_worker_nodes, rw_parallel_units #10656
    • rw_connections, rw_databases, rw_functions, rw_indexes, rw_materialized_views, rw_schemas, rw_sinks, rw_sources, rw_tables, rw_users, rw_views #10593

• Supports GROUP BY output alias or index. #10305

• Supports using scalar functions in the FROM clause. #10317

• Supports tagging the created VPC endpoints when creating a PrivateLink connection. #10582

Connectors

• Breaking change: When creating a source or table with a connector whose schema is auto-resolved from an external format file, the syntax for defining primary keys within column definitions is replaced with the table constraint syntax. #10195

  CREATE TABLE debezium_non_compact (order_id int PRIMARY KEY) WITH (
  connector = 'kafka',
  kafka.topic = 'debezium_non_compact_avro_json',
  kafka.brokers = 'message_queue:29092',
  kafka.scan.startup.mode = 'earliest'
  ) ROW FORMAT DEBEZIUM_AVRO ROW SCHEMA LOCATION CONFLUENT SCHEMA REGISTRY 'http://message_queue:8081';

  CREATE TABLE debezium_non_compact (PRIMARY KEY(order_id)) WITH ( ...

• Breaking change: Modifies the syntax for specifying data and encoding formats for a source in CREATE SOURCE and CREATE TABLE commands. For v1.0.0, the old syntax is still accepted but will be deprecated in the next release. #10768

  Old syntax - part 1:

  ROW FORMAT data_format 
  [ MESSAGE 'message' ]
  [ ROW SCHEMA LOCATION ['location' | CONFLUENT SCHEMA REGISTRY 'schema_registry_url' ] ];

  New syntax - part 1:

  FORMAT data_format ENCODE data_encode (
      message = 'message',
      schema_location = 'location' | confluent_schema_registry = 'schema_registry_url'
  );

  Old syntax - part 2:

  ROW FORMAT csv WITHOUT HEADER DELIMITED BY ',';

  New syntax - part 2:

  FORMAT PLAIN ENCODE CSV (
      without_header = 'true',
      delimiter = ','
  );

• Supports sinking data to Delta Lake. #10374, #10580

• Supports sinking data to AWS Kinesis. #10437

• Supports BYTES as a row format. #10592

• Supports specifying schema for the PostgreSQL sink. #10576

• Supports using the user-provided publication to create a PostgreSQL CDC table. #10804

Full Changelog: v0.19.0...v1.0.0