Uses of Class
com.databricks.jdbc.api.impl.arrow.ArrowResultChunk
-
Packages that use ArrowResultChunk Package Description com.databricks.jdbc.api.impl.arrow com.databricks.jdbc.api.impl.streaming -
-
Uses of ArrowResultChunk in com.databricks.jdbc.api.impl.arrow
Methods in com.databricks.jdbc.api.impl.arrow that return ArrowResultChunk Modifier and Type Method Description ArrowResultChunkArrowResultChunk.Builder. build()protected ArrowResultChunkRemoteChunkProvider. createChunk(StatementId statementId, long chunkIndex, TSparkArrowResultLink resultLink)Creates chunkAbstractRemoteChunkProviderbased on theTSparkArrowResultLink.protected ArrowResultChunkRemoteChunkProvider. createChunk(StatementId statementId, long chunkIndex, com.databricks.sdk.service.sql.BaseChunkInfo chunkInfo)Creates chunkAbstractRemoteChunkProviderbased on theBaseChunkInfo.ArrowResultChunkInlineChunkProvider. getChunk()Retrieves the current chunk of data after a successful call toChunkProvider.next().Constructors in com.databricks.jdbc.api.impl.arrow with parameters of type ArrowResultChunk Constructor Description StreamingChunkDownloadTask(ArrowResultChunk chunk, IDatabricksHttpClient httpClient, CompressionCodec compressionCodec, ChunkLinkFetcher linkFetcher, double cloudFetchSpeedThreshold) -
Uses of ArrowResultChunk in com.databricks.jdbc.api.impl.streaming
Methods in com.databricks.jdbc.api.impl.streaming that return types with arguments of type ArrowResultChunk Modifier and Type Method Description static ThriftStreamingProvider<ArrowResultChunk>ThriftStreamingProvider. forInlineArrow(ThriftBatchFetcher fetcher, TFetchResultsResp initialResponse, StatementId statementId, int maxBatchesInMemory, int timeoutSeconds)Creates a streaming provider for Inline Arrow results.Consumer<ArrowResultChunk>InlineArrowResponseProcessor. getReleaseAction()StreamingBatch<ArrowResultChunk>InlineArrowResponseProcessor. processInitialResponse(TFetchResultsResp response)StreamingBatch<ArrowResultChunk>InlineArrowResponseProcessor. processResponse(TFetchResultsResp response, long batchIndex, long rowOffset)
-