import { BaseClientManager } from "../../../../confluent/base-client-manager.js";
export interface FlinkSqlResult {
    success: boolean;
    data?: unknown[];
    error?: string;
    statementName?: string;
    phase?: string;
}
/**
 * `_meta` payload emitted by catalog handlers so integration tests can sweep
 * statements the handler created internally. {@linkcode executeFlinkSql}
 * best-effort deletes its own bounded statements once they complete; this
 * ride-along remains as a backstop for the cases where that delete fails.
 *
 * Declared as `type` rather than `interface` so the shape is assignable to
 * {@link BaseToolHandler.createResponse}'s `_meta: Record<string, unknown>`
 * parameter; interfaces are excluded from that target by declaration-merging
 * rules (microsoft/TypeScript#15300).
 */
export type FlinkStatementMeta = {
    flinkStatementsCreated: string[];
};
export interface FlinkSqlOptions {
    organizationId: string;
    environmentId: string;
    computePoolId: string;
    catalogName?: string;
    databaseName?: string;
    timeoutMs?: number;
}
/**
 * Executes a Flink SQL query and returns the results.
 * For bounded queries (like INFORMATION_SCHEMA), waits for statement to complete,
 * then fetches all results and deletes the spent statement.
 */
export declare function executeFlinkSql(clientManager: BaseClientManager, sql: string, options: FlinkSqlOptions): Promise<FlinkSqlResult>;
//# sourceMappingURL=flink-sql-helper.d.ts.map