import { BaseClientManager } from "../../../../confluent/base-client-manager.js"; export interface FlinkSqlResult { success: boolean; data?: unknown[]; error?: string; statementName?: string; phase?: 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. */ export declare function executeFlinkSql(clientManager: BaseClientManager, sql: string, options: FlinkSqlOptions): Promise; //# sourceMappingURL=flink-sql-helper.d.ts.map