Package com.databricks.jdbc.api.impl.arrow

Class StreamingChunkDownloadTask

java.lang.Object

com.databricks.jdbc.api.impl.arrow.StreamingChunkDownloadTask

All Implemented Interfaces:

Callable<Void>

public class StreamingChunkDownloadTask
extends Object
implements Callable<Void>

A download task for streaming chunk provider. Uses a LinkRefresher callback for link refresh, which enables the StreamingChunkProvider to coalesce concurrent expired-link refreshes into a single batch RPC.

Constructor Summary

Constructors

Constructor	Description
StreamingChunkDownloadTask(ArrowResultChunk chunk, IDatabricksHttpClient httpClient, CompressionCodec compressionCodec, com.databricks.jdbc.api.impl.arrow.LinkRefresher linkRefresher, double cloudFetchSpeedThreshold)

Method Summary

Modifier and Type	Method	Description
Void	call()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamingChunkDownloadTask

public StreamingChunkDownloadTask(ArrowResultChunk chunk,
                                  IDatabricksHttpClient httpClient,
                                  CompressionCodec compressionCodec,
                                  com.databricks.jdbc.api.impl.arrow.LinkRefresher linkRefresher,
                                  double cloudFetchSpeedThreshold)

Method Detail

call

public Void call()
          throws DatabricksSQLException

Specified by:

call in interface Callable<Void>

Throws:

DatabricksSQLException