Chroma’s official MCP server: vector search and collection management for RAG workflows.
Nothing to run from here
RisingWave is installed from its publisher's own source and answers where it runs, so this marketplace is not in the path of a single call. There is no address here to send one to, and a panel that pretended otherwise would be showing you an answer we made up. Install it and call it from your own client — the Installation tab has the entry for each one.
144
tools declared
—
trust score
local
runs on your machine
—
calls last 7d
What it does
Query, inspect and operate RisingWave, the PostgreSQL-compatible streaming database, from an agent.
Quickstart
# 1 — add it to Claude Code
claude mcp add --scope user --env 'RISINGWAVE_CONNECTION_STR=${RISINGWAVE_CONNECTION_STR}' --transport stdio risingwave-mcp '--' docker run -i --rm -e RISINGWAVE_CONNECTION_STR docker.io/risingwavelabs/risingwave-mcp-server:0.1.1
# 2 — ask your agent for something these tools do
# get_worker_nodes, get_actor_distribution, get_fragment_stats and 141 more
It needs RISINGWAVE_CONNECTION_STR: this reads it from your environment, so export it first.
RisingWave costs nothing on mcprush: there is no plan to choose here, no cap to set and nothing mcprush can bill you for.
Publishernot claimed
RIAll 1 server
risingwavelabs1 server
1 category
Collected from a public index. Nobody has claimed this account, so nothing here was written by its author — claim it if it is yours.
Installation
Where are you running it?
Every route below installs the same thing and ends at the same approval screen. This one runs on your machine: your client starts RisingWave as a process under your own user, with your files and your network, so the tool surface below is what it can do to your computer rather than to a server somewhere else. It has not been scanned here, so read the surface, and its source, before you approve it.
Claude Codedeclared by this listing
This is a public server: you run it yourself and this marketplace is not in the path. You need Docker installed and running. Only the required variables are passed into the container. To set an optional one (MCP_TRANSPORT), add -e NAME before the image name and give it a value in the entry’s env: an unset -e would clear the default the image sets. Claude Code registers it in one command; --scope user makes it available in every project. Claude Code reads RISINGWAVE_CONNECTION_STR (PostgreSQL connection string for RisingWave, e.g. postgresql://user:password@host:4566/dev. Use a user with SELECT on the views the agent may read) from your environment each time it starts the server, so the value stays out of its config: export it in your shell profile (macOS, Linux), or run setx RISINGWAVE_CONNECTION_STR … and open a new terminal (Windows). The '--' is in quotes so that PowerShell passes it on.
claude mcp add --scope user --env 'RISINGWAVE_CONNECTION_STR=${RISINGWAVE_CONNECTION_STR}' --transport stdio risingwave-mcp '--' docker run -i --rm -e RISINGWAVE_CONNECTION_STR docker.io/risingwavelabs/risingwave-mcp-server:0.1.1Reconnect, or start a new session, and the tools appear in the model’s tool list.
Free on mcprush, and it runs from its publisher’s own image: this marketplace is not in the path, so there is no key of ours to hold and no card to add.
What it asks of you
It reaches a system of yours, so it needs settings only you can give it: RISINGWAVE_CONNECTION_STR — PostgreSQL connection string for RisingWave, e.g. postgresql://user:password@host:4566/dev. Use a user with SELECT on the views the agent may read.. You set it in your own client’s config, on your machine — this marketplace never holds it.
What it writes
One config entry your client uses to start the process locally. A local server runs with your file system and your network, which is why it is priced without metering.
What you approve
144 tools, with what each one reads, writes and reaches shown before you agree — the same list on every route above. Read the tool surface.
Tool surface
What the model actually sees. Descriptions are diffed on every release — see version history.
Read from its source code. A server that builds its tool list when it starts can list more tools than this.
Get all worker nodes in the RisingWave cluster with their status and resources.
Takes no parameters.
Show actor count distribution across worker nodes.
Takes no parameters.
Get statistics about fragments in the cluster including total count, parallelism distribution, and communication cost.
Takes no parameters.
Calculate total cross-fragment data shuffle overhead in the cluster.
Takes no parameters.
List all fragments in the cluster, optionally filtered by table ID.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_id | integer | no | Optional table ID to filter fragments for a specific streaming job. |
Get detailed information about a specific fragment including its execution plan.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to inspect. |
List all actors in the cluster, optionally filtered by fragment or worker.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | no | Optional fragment ID to filter actors. |
| worker_id | integer | no | Optional worker ID to filter actors on a specific node. |
Get all actors running a specific fragment with their worker node info.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to get actors for. |
Get the internal ID of a database object by its name.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| name | string | yes | Name of the object. |
| object_type | string | no | Type of object - 'mv' for materialized view, 'table' for table, 'sink' for sink, 'source' for source. |
Find the materialized view that owns a specific fragment.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to look up. |
Trace an actor back to its owning materialized view or table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| actor_id | integer | yes | The actor ID to trace. |
Find which worker node is running a specific actor.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| actor_id | integer | yes | The actor ID to look up. |
Find all worker nodes running actors for a specific fragment.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to look up. |
Get all fragments for a streaming job (MV, table, or sink).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| job_name | string | yes | Name of the streaming job. |
| job_type | string | no | Type of job - 'mv', 'table', or 'sink'. |
Get all actors for a streaming job with their worker node assignments.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| job_name | string | yes | Name of the streaming job. |
| job_type | string | no | Type of job - 'mv', 'table', or 'sink'. |
Get the backfill progress for all streaming jobs currently being created.
Takes no parameters.
Get detailed fragment-level backfill progress.
Takes no parameters.
Get the upstream fragments that feed data into a specific fragment.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to get upstream fragments for. |
Get the downstream fragments that consume data from a specific fragment.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| fragment_id | integer | yes | The fragment ID to get downstream fragments for. |
Find fragments that use a specific state table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| state_table_id | integer | yes | The state table ID to look up. |
Get an overview of parallelism settings for all streaming jobs.
Takes no parameters.
Get the distribution of actors across worker nodes for a materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view. |
Find the streaming job (MV, table, sink, or source) that owns a state table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| state_table_id | integer | yes | The state table ID to look up. |
Get all internal state tables for a streaming job.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| job_name | string | no | Name of the streaming job (optional if job_id is provided). |
| job_id | integer | no | ID of the streaming job (optional if job_name is provided). |
| schema_name | string | no | Schema name (default: "public"), used with job_name. |
Check vnode distribution for a table to detect data skew.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to check. |
| distribution_key | string | yes | The column used as distribution key. |
| vnode_count | integer | no | Number of vnodes (default: 256). Check your cluster config if unsure. |
Find all materialized views that depend on a given table or MV.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| object_name | string | yes | Name of the table or materialized view. |
Find all tables and materialized views that a given MV depends on.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view. |
Check whether sinks are decoupled or not.
Takes no parameters.
Monitor the lag of a decoupled sink by querying its internal log store table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| internal_table_name | string | yes | Name of the sink's internal log store table. |
Get all constraints for a specific table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| schema_name | string | no | Schema name (default: "public") |
Get information about all views in a schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Schema name (default: "public") |
List all database objects (tables, MVs, sources, sinks, views) in a schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Schema name (default: "public") |
Get comments/descriptions attached to database objects.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| object_type | string | no | Optional filter by object type ('table', 'column', etc.) |
| object_name | string | no | Optional filter by object name |
Get status of all streaming jobs from the system catalog.
Takes no parameters.
List all available system tables and views in rw_catalog.
Takes no parameters.
Query a specific system catalog table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| catalog_table | string | yes | Name of the system catalog table (e.g., 'rw_relations', 'rw_actors') |
| limit | integer | no | Maximum number of rows to return (default: 100) |
Display cluster node details including address, type, state, and resources.
Takes no parameters.
List all active streaming jobs (creating materialized views, indexes, tables, sinks, sources).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| like_pattern | string | no | Optional pattern to filter jobs by name (e.g., 'mv_%') |
Cancel one or more running streaming jobs.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| job_ids | string | yes | Comma-separated job IDs to cancel (e.g., "1010" or "1010, 1012") |
Manually trigger an ad-hoc recovery operation.
Takes no parameters.
Get comprehensive cluster information including meta, compute, frontend, and compactor nodes.
Takes no parameters.
List all connections in the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Optional schema name to filter connections. If not specified, lists connections from all schemas in the current search_path. |
Show the CREATE CONNECTION statement for a specific connection.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| connection_name | string | yes | Name of the connection |
Drop a connection from the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| connection_name | string | yes | Name of the connection to drop |
| if_exists | boolean | no | If True, do not error if connection does not exist |
| cascade | boolean | no | If True, also drop dependent objects (not supported for Iceberg) |
Create a new schema in the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | yes | Name of the schema to create |
| if_not_exists | boolean | no | If True, do not error if schema already exists (default: True) |
Drop a table from the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to drop (can include schema prefix) |
| if_exists | boolean | no | If True, do not error if table does not exist |
| cascade | boolean | no | If True, also drop dependent objects |
Add a new column to an existing table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| column_name | string | yes | Name of the new column |
| data_type | string | yes | Data type of the column (e.g., 'VARCHAR', 'INT', 'TIMESTAMP') |
| default_value | string | no | Optional default value for the column |
Remove a column from an existing table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| column_name | string | yes | Name of the column to drop |
| if_exists | boolean | no | If True, do not error if column does not exist |
Rename a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Current name of the table |
| new_name | string | yes | New name for the table |
Change the parallelism of a table (for tables with connectors).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| parallelism | string | yes | Either 'ADAPTIVE' or a fixed number (e.g., '4') |
Modify the source ingestion rate limit for a connector-based table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| rate_limit | string | yes | Either 'default' or a numeric value (records per second) |
Create a new materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| name | string | yes | Name of the materialized view |
| sql_statement | string | yes | SQL statement for the materialized view |
| schema_name | string | no | Schema name (default: "public") |
Drop a materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| name | string | yes | Name of the materialized view to drop |
| schema_name | string | no | Schema name (default: "public") |
Execute a DDL (Data Definition Language) statement like CREATE TABLE, CREATE SCHEMA, etc.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sql_statement | string | yes | The DDL SQL statement to execute |
Change the parallelism of a materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view |
| parallelism | string | yes | Either 'ADAPTIVE', '0' (for ADAPTIVE), or a fixed number (e.g., '4') |
Modify the backfill rate limit for a materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view |
| rate_limit | string | yes | Either 'default', '0' (to pause), or a numeric value |
Rename a materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Current name of the materialized view |
| new_name | string | yes | New name for the materialized view |
Atomically swap the names of two materialized views.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the first materialized view |
| target_mv_name | string | yes | Name of the second materialized view to swap with |
Create a table in RisingWave, storing the streaming data from kafka into RisingWave.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| name | string | yes | Name of the table |
| columns | string | yes | Schema/columns of the table (e.g., "id INT, name VARCHAR, timestamp TIMESTAMP") |
| topic | string | yes | Name of kafka topic being sourced from |
| bootstrap_server | string | no | Kafka bootstrap server address (default: "localhost:9092") |
| format_type | string | no | Data format - PLAIN, UPSERT, DEBEZIUM, etc. (default: "PLAIN") |
| encode_type | string | no | Encoding - JSON, AVRO, PROTOBUF, CSV, BYTES (default: "JSON") |
Add a comment/description to a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| comment | string | yes | Comment text to add |
Add a comment/description to a column.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table containing the column |
| column_name | string | yes | Name of the column |
| comment | string | yes | Comment text to add |
Insert a single row into a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| column_data | string | yes | JSON string of column names and values (e.g., '{"col1": "value1", "col2": 123}') |
| schema_name | string | no | Name of the schema (default: "public") |
Update rows in a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to update |
| set_clause | string | yes | Column assignments (e.g., "city = 'New York', status = 'active'") |
| where_clause | string | no | Optional condition to filter rows (e.g., "id = 5") If omitted, ALL rows will be updated! |
| returning_columns | string | no | Optional columns to return (e.g., "id, city") |
| confirm_no_where | boolean | no | Must be True to update all rows without a WHERE clause |
Delete rows from a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to delete from |
| where_clause | string | no | Optional condition to filter rows (e.g., "id = 5") If omitted, ALL rows will be deleted! |
| returning_columns | string | no | Optional columns to return from deleted rows (e.g., "id") |
| confirm_no_where | boolean | no | Must be True to delete all rows without a WHERE clause |
Insert multiple rows into a table using a single INSERT statement.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| columns | string | yes | Comma-separated column names (e.g., "id, name, value") |
| values_list | string | yes | Values in SQL format, rows separated by ), ( (e.g., "(1, 'Alice', 100), (2, 'Bob', 200)") |
| schema_name | string | no | Name of the schema (default: "public") |
Search RisingWave documentation for relevant information.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| query | string | yes | Search keywords (e.g., "kafka source connector", "watermark", "CREATE MATERIALIZED VIEW", "iceberg sink", "data types") |
| max_results | integer | no | Maximum number of matching sections to return (default: 3) |
Get a specific documentation section by name.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| section_name | string | yes | Name of the section (case-insensitive, partial match supported) |
List all available documentation sections.
Takes no parameters.
List all user-defined functions in the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Optional schema name to filter functions. If not specified, lists functions from all schemas in the current search_path. |
Show the CREATE FUNCTION statement for a specific function.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| function_name | string | yes | Name of the function |
| argument_types | string | no | Optional comma-separated argument types (e.g., "int, varchar") to disambiguate overloaded functions |
Drop a user-defined function.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| function_name | string | yes | Name of the function to drop |
| argument_types | string | no | Optional comma-separated argument types (e.g., "int, varchar") to disambiguate overloaded functions. If the function name is unique in its schema, this can be omitted. |
| if_exists | boolean | no | If True, do not error if function does not exist |
| cascade | boolean | no | If True, also drop dependent objects (like materialized views) |
Expire old snapshots on an Iceberg table or sink, freeing up space.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the Iceberg table or sink |
| schema_name | string | no | Schema name (default: "public") |
Perform full compaction on an Iceberg table followed by snapshot expiration.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the Iceberg table or sink |
| schema_name | string | no | Schema name (default: "public") |
Query an Iceberg source at a specific point in time (time travel).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the Iceberg source |
| select_columns | string | no | Columns to select (default: "*") |
| where_clause | string | no | Optional WHERE condition (without the WHERE keyword) |
| timestamp | string | no | Query as of this timestamp (e.g., '2024-01-01 12:00:00') |
| snapshot_id | integer | no | Query as of this specific snapshot ID |
Get all snapshots of an Iceberg source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the Iceberg source |
Get data files of an Iceberg source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the Iceberg source |
Get manifest files of an Iceberg source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the Iceberg source |
Get the history of an Iceberg source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the Iceberg source |
Get the refresh state of Iceberg tables using full reload mode.
Takes no parameters.
Create an Iceberg sink to stream data from RisingWave to an Iceberg table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name for the sink |
| source_object | string | yes | Source table, MV, or query to sink from |
| warehouse_path | string | yes | S3 path to Iceberg warehouse (e.g., 's3://bucket/warehouse') |
| database_name | string | yes | Iceberg database/namespace name |
| table_name | string | yes | Iceberg table name |
| catalog_type | string | no | Catalog type - 'storage', 'rest', or 'glue' (default: 'storage') |
| sink_type | string | no | 'append-only' or 'upsert' (default: 'append-only') |
| primary_key | string | no | Required for upsert - comma-separated key columns |
| partition_by | string | no | Optional partition columns (e.g., 'date,region') |
| force_append_only | boolean | no | Convert updates/deletes to inserts (default: false) |
| create_table_if_not_exists | boolean | no | Auto-create table if missing (default: false) |
| commit_checkpoint_interval | integer | no | Commit frequency in seconds (default: 60) |
| s3_region | string | no | AWS S3 region |
| s3_access_key | string | no | AWS access key (consider using secrets instead) |
| s3_secret_key | string | no | AWS secret key (consider using secrets instead) |
Create an Iceberg source to read data from an Iceberg table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name for the source |
| warehouse_path | string | yes | S3 path to Iceberg warehouse (e.g., 's3://bucket/warehouse') |
| database_name | string | yes | Iceberg database/namespace name |
| table_name | string | yes | Iceberg table name |
| catalog_type | string | no | Catalog type - 'storage', 'rest', or 'glue' (default: 'storage') |
| s3_region | string | no | AWS S3 region |
| s3_access_key | string | no | AWS access key (consider using secrets instead) |
| s3_secret_key | string | no | AWS secret key (consider using secrets instead) |
List all indexes for a specific table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to list indexes for |
Describe the structure of an index.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| index_name | string | yes | Name of the index to describe |
Show the CREATE INDEX statement for a specific index.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| index_name | string | yes | Name of the index |
Drop an index from a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| index_name | string | yes | Name of the index to drop |
| if_exists | boolean | no | If True, do not error if index does not exist |
| cascade | boolean | no | If True, also drop dependent objects |
Get the RisingWave database version information.
Takes no parameters.
Show currently running queries (if supported by RisingWave version).
Takes no parameters.
Force flush all pending writes to the database.
Takes no parameters.
Get system event logs for debugging and auditing.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| event_type | string | no | Optional filter by event type (e.g., 'CREATE_STREAM_JOB', 'BARRIER_COMPLETE', 'RECOVERY') |
| limit | integer | no | Maximum number of events to return (default: 50) |
Get current rate limit configuration for all fragments.
Takes no parameters.
Get configuration parameters for streaming jobs.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| job_name | string | no | Optional job name to filter. If not specified, shows all jobs. |
Get progress of active compaction tasks.
Takes no parameters.
Get an overview of all streaming jobs with their status and parallelism.
Takes no parameters.
Get information about the last cluster recovery event.
Takes no parameters.
Get object dependency information from the system catalog.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| object_name | string | no | Optional name to filter dependencies for a specific object |
List all tables in the database.
Takes no parameters.
List all databases in the RisingWave cluster.
Takes no parameters.
Describe the structure of a table (columns, types, etc.).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to describe |
Describe the structure of a materialized view (columns, types, etc.).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view to describe |
Show the CREATE TABLE statement for a specific table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
Show the CREATE MATERIALIZED VIEW statement for a specific materialized view.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| mv_name | string | yes | Name of the materialized view |
Check if a table or materialized view exists in the specified schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table to check |
| schema_name | string | no | Name of the schema (default: "public") |
List all schemas in the RisingWave database.
Takes no parameters.
List all materialized views in a specific schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Name of the schema (default: "public") |
Get detailed column information for a table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| schema_name | string | no | Name of the schema (default: "public") |
List all subscriptions in a specific schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Name of the schema (default: "public") |
List privileges for a specific table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_name | string | yes | Name of the table |
| schema_name | string | no | Name of the schema (default: "public") |
List all sinks in the RisingWave database.
Takes no parameters.
Show the CREATE SINK statement for a specific sink.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name of the sink |
Get information about a relation (table, MV, source, sink, etc.) by name.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| relation_name | string | yes | Name of the relation to look up. |
Show the CREATE SOURCE statement for a specific source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source |
List all secrets in the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Optional schema name to filter secrets. If not specified, lists secrets from all schemas in the current search_path. |
Drop a secret from the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| secret_name | string | yes | Name of the secret to drop |
Set a session variable/runtime parameter in RisingWave.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| variable_name | string | yes | Name of the session variable to set |
| value | string | yes | Value to set (use 'DEFAULT' to reset to default) |
Show the current value of a session variable/runtime parameter.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| variable_name | string | yes | Name of the session variable to show |
Show all session variables/runtime parameters and their current values.
Takes no parameters.
Alter a system-wide default for a runtime parameter.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| variable_name | string | yes | Name of the system variable to alter |
| value | string | yes | Value to set (use 'DEFAULT' to reset to default) |
Describe the structure of a sink (columns, types, etc.).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name of the sink to describe |
Change the parallelism of a sink.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name of the sink to alter |
| parallelism | string | yes | Either 'ADAPTIVE' or a fixed number (e.g., '4'), or '0' for ADAPTIVE |
Modify the output rate limit for a sink.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name of the sink to alter |
| rate_limit | string | yes | Either 'default' or a numeric value (records per second) |
Rename a sink.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Current name of the sink |
| new_name | string | yes | New name for the sink |
Drop a sink from the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| sink_name | string | yes | Name of the sink to drop |
| if_exists | boolean | no | If True, do not error if sink does not exist |
| cascade | boolean | no | If True, also drop dependent objects |
List all sources in the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| schema_name | string | no | Optional schema name to filter sources. If not specified, lists sources from all schemas in the current search_path. |
Describe the structure of a source (columns, types, etc.).
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source to describe |
Change the parallelism of a source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source to alter |
| parallelism | string | yes | Either 'ADAPTIVE' or a fixed number (e.g., '4') |
Modify the ingestion rate limit for a source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source to alter |
| rate_limit | string | yes | Either 'default' or a numeric value (records per second) |
Fetch the latest schema from the schema registry and update the source schema.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source to refresh |
Rename a source.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Current name of the source |
| new_name | string | yes | New name for the source |
Drop a source from the database.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| source_name | string | yes | Name of the source to drop |
| if_exists | boolean | no | If True, do not error if source does not exist |
| cascade | boolean | no | If True, also drop dependent objects (materialized views, etc.) |
Get the physical storage size and key count of a specific table.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_id | integer | yes | The internal table ID to inspect. |
Get physical storage statistics for all tables.
Takes no parameters.
Check the SST (Sorted String Table) layout per compaction level.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| compaction_group_id | integer | no | Optional compaction group ID to filter. If not provided, shows stats for all groups. |
Get compaction group configurations including write stop limits.
Takes no parameters.
Check delete ratio of SSTs containing a specific table ID.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_id | integer | yes | The table ID to check delete ratios for. |
Check vnode distribution in SSTs for a specific table ID.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| table_id | integer | yes | The table ID to check vnode distribution for. |
Find state tables with large volume in a specific compaction group.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| compaction_group_id | integer | yes | The compaction group ID to inspect. |
| min_size_gb | number | no | Minimum size in GB to filter results (default: 0). |
Get L0 level statistics for a compaction group.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| compaction_group_id | integer | yes | The compaction group ID to inspect. |
Find all streaming jobs that have a state table in a specific compaction group.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| compaction_group_id | integer | yes | The compaction group ID to inspect. |
Get metadata snapshot information including creation times.
Takes no parameters.
Get a summary of all compaction groups with their storage usage.
Takes no parameters.
List all users in the RisingWave database.
Takes no parameters.
Get all privileges granted to a specific user.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| username | string | yes | Name of the user to check privileges for |
Get schema-level information for a specific user.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| username | string | yes | Name of the user to check privileges for |
Get database-level information for a specific user.
| Parameter | Type | Required | Notes |
|---|---|---|---|
| username | string | yes | Name of the user to check privileges for |
Free
$0 forever
- Every tool, no call limit
- No card, and mcprush charges nothing for it
- Source is public, though no licence is declared for it
- Runs on your machine — nothing of it reaches our gateway
- Nothing to cap, because mcprush bills nothing
What counts against your monthly calls
| Tool | Unit | Calls used | Out of the allowance |
|---|
Nothing here is billable: mcprush charges nothing to install RisingWave or to call it, at any volume.
Call allowance · this installenforced at the gateway
Monthly allowance, in calls
—
—
Alert at 80% · then the tool returns a normal MCP error
Used this month: —
—Grade not published
No rule-by-rule report on file for this release
Two independent axes, because powerful and malicious are different questions. The grade is threat only. The capability level is blast radius, and it is never a penalty on the grade — it is priced as one subtract-only term in the score, where you can see it.
This listing ships as a container image. The scanner reads packages on npm and PyPI and public source; an image is neither, so there is no grade here — not a withheld one, an unmeasured one.
Release history
It installs from a container image rather than from a versioned package, so the command cannot be pinned to a release. The history below is for reading; the current release on file is 0.1.1.
0.1.1
undated
latestNo release note was published with this version.
—
no reviews yet
Who can review
One review per account, from a signed-in account that does not publish this listing. Nothing else is asked — you can say what you think before you install it. Publishers can reply once per review, and a review can be edited or deleted by whoever wrote it.
Sign in to write one
Any signed-in account that does not publish RisingWave can review it, once — before installing it or after. A review from an account that has installed it is marked as one.
No reviews yet
Nobody has reviewed this listing. The rating on the card is the mean of the reviews written here and nothing else, so there is no rating until somebody writes the first — which takes a signed-in account that does not publish it, and nothing else.