import { TGetResultSetMetadataResp, TRowSet } from '../../thrift/TCLIService_types'; import IClientContext from '../contracts/IClientContext'; import IResultsProvider, { ResultsProviderFetchNextOptions } from './IResultsProvider'; import { ArrowBatch } from './utils'; export default class CloudFetchResultHandler implements IResultsProvider { private readonly context; private readonly source; private readonly isLZ4Compressed; private readonly statementId?; private pendingLinks; private downloadTasks; private chunkIndex; constructor(context: IClientContext, source: IResultsProvider, metadata: TGetResultSetMetadataResp, statementId?: string); hasMore(): Promise; fetchNext(options: ResultsProviderFetchNextOptions): Promise; private logDownloadMetrics; private downloadLink; private fetch; /** * Emit cloudfetch.chunk telemetry event. * CRITICAL: All exceptions swallowed and logged at LogLevel.debug ONLY. */ private emitCloudFetchChunk; }