import { AnyType } from '@lightdash/common'; import { Connection, Submittable } from 'pg'; import { Readable } from 'stream'; interface QueryStreamConfig { batchSize?: number; highWaterMark?: number; rowMode?: 'array'; types?: AnyType; } declare class QueryStream extends Readable implements Submittable { cursor: AnyType; _result: AnyType; handleRowDescription: Function; handleDataRow: Function; handlePortalSuspended: Function; handleCommandComplete: Function; handleReadyForQuery: Function; handleError: Function; handleEmptyQuery: Function; constructor(text: string, values?: AnyType[], config?: QueryStreamConfig); submit(connection: Connection): void; _destroy(_err: Error, cb: Function): void; _read(size: number): void; } export default QueryStream; //# sourceMappingURL=PgQueryStream.d.ts.map