mcp-confluent

Official
by confluentinc

read-flink-statement

Retrieve and analyze Flink statements and their results by querying the Flink REST API. Specify the statement name, organization, and environment to access real-time data streams or sampled results.

Instructions

Make a request to read a statement and its results

Input Schema

NameRequiredDescriptionDefault
baseUrlNoThe base URL of the Flink REST API.
environmentIdNoThe unique identifier for the environment.
organizationIdNoThe unique identifier for the organization.
statementNameYesThe user provided name of the resource, unique within this environment.
timeoutInMillisecondsNoThe function implements pagination. It will continue to fetch results using the next page token until either there are no more results or the timeout is reached. Tables backed by kafka topics can be thought of as never-ending streams as data could be continuously produced in near real-time. Therefore, if you wish to sample values from a stream, you may want to set a timeout. If you are reading a statement after creating it, you may need to retry a couple times to ensure that the statement is ready and receiving data.

Input Schema (JSON Schema)

{ "$schema": "http://json-schema.org/draft-07/schema#", "additionalProperties": false, "properties": { "baseUrl": { "default": "", "description": "The base URL of the Flink REST API.", "format": "uri", "type": "string" }, "environmentId": { "description": "The unique identifier for the environment.", "type": "string" }, "organizationId": { "description": "The unique identifier for the organization.", "type": "string" }, "statementName": { "description": "The user provided name of the resource, unique within this environment.", "maxLength": 100, "minLength": 1, "pattern": "[a-z0-9]([-a-z0-9]*[a-z0-9])?(\\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*", "type": "string" }, "timeoutInMilliseconds": { "default": 60000, "description": "The function implements pagination. It will continue to fetch results using the next page token until either there are no more results or the timeout is reached. Tables backed by kafka topics can be thought of as never-ending streams as data could be continuously produced in near real-time. Therefore, if you wish to sample values from a stream, you may want to set a timeout. If you are reading a statement after creating it, you may need to retry a couple times to ensure that the statement is ready and receiving data.", "type": "number" } }, "required": [ "statementName" ], "type": "object" }
ID: 8zh4gg3sw9