Uses of Class
com.databricks.jdbc.dbclient.impl.common.StatementId
Packages that use StatementId
Package
Description
-
Uses of StatementId in com.databricks.jdbc.api.impl
Methods in com.databricks.jdbc.api.impl that return StatementIdMethods in com.databricks.jdbc.api.impl with parameters of type StatementIdModifier and TypeMethodDescriptionvoidDatabricksStatement.setStatementId(StatementId statementId) Constructors in com.databricks.jdbc.api.impl with parameters of type StatementIdModifierConstructorDescriptionDatabricksResultSet(StatementStatus statementStatus, StatementId statementId, StatementType statementType, IDatabricksStatementInternal parentStatement, IExecutionResult executionResult, DatabricksResultSetMetaData resultSetMetaData, boolean complexDatatypeSupport) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, TFetchResultsResp resultsResp, StatementType statementType, IDatabricksStatementInternal parentStatement, IDatabricksSession session) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, ResultData resultData, ResultManifest resultManifest, StatementType statementType, IDatabricksSession session, IDatabricksStatementInternal parentStatement) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<ColumnMetadata> columnMetadataList, List<List<Object>> rows, StatementType statementType) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<String> columnNames, List<String> columnTypeText, int[] columnTypes, int[] columnTypePrecisions, int[] isNullables, Object[][] rows, StatementType statementType) DatabricksResultSet(StatementStatus statementStatus, StatementId statementId, List<String> columnNames, List<String> columnTypeText, List<Integer> columnTypes, List<Integer> columnTypePrecisions, List<Nullable> columnNullables, List<List<Object>> rows, StatementType statementType) DatabricksResultSetMetaData(StatementId statementId, TGetResultSetMetadataResp resultManifest, long rows, long chunkCount, List<String> arrowMetadata, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for a Thrift-based result set.DatabricksResultSetMetaData(StatementId statementId, ResultManifest resultManifest, boolean usesExternalLinks, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for a SEA result set.DatabricksResultSetMetaData(StatementId statementId, List<ColumnMetadata> columnMetadataList, long totalRows) Constructs aDatabricksResultSetMetaDataobject for metadata result set (SEA Flow)DatabricksResultSetMetaData(StatementId statementId, List<String> columnNames, List<String> columnTypeText, int[] columnTypes, int[] columnTypePrecisions, int[] isNullables, long totalRows) Constructs aDatabricksResultSetMetaDataobject for predefined metadata result set.DatabricksResultSetMetaData(StatementId statementId, List<String> columnNames, List<String> columnDataTypes, IDatabricksConnectionContext ctx) Constructs aDatabricksResultSetMetaDataobject for metadata result set obtained from DESCRIBE QUERY Works for both SEA and Thrift flows as result set obtained from DESCRIBE QUERY is already parsed.DatabricksResultSetMetaData(StatementId statementId, List<String> columnNames, List<String> columnTypeText, List<Integer> columnTypes, List<Integer> columnTypePrecisions, List<Nullable> columnNullables, long totalRows) Constructs aDatabricksResultSetMetaDataobject for metadata result set (Thrift Flow)DatabricksStatement(DatabricksConnection connection, StatementId statementId) -
Uses of StatementId in com.databricks.jdbc.api.impl.arrow
Fields in com.databricks.jdbc.api.impl.arrow declared as StatementIdModifier and TypeFieldDescriptionprotected final StatementIdAbstractArrowResultChunk.statementIdprotected final StatementIdAbstractRemoteChunkProvider.statementIdMethods in com.databricks.jdbc.api.impl.arrow with parameters of type StatementIdModifier and TypeMethodDescriptionprotected abstract TAbstractRemoteChunkProvider.createChunk(StatementId statementId, long chunkIndex, TSparkArrowResultLink resultLink) Creates chunkAbstractRemoteChunkProviderbased on theTSparkArrowResultLink.protected abstract TAbstractRemoteChunkProvider.createChunk(StatementId statementId, long chunkIndex, com.databricks.sdk.service.sql.BaseChunkInfo chunkInfo) Creates chunkAbstractRemoteChunkProviderbased on theBaseChunkInfo.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.ArrowResultChunk.Builder.withStatementId(StatementId statementId) Constructors in com.databricks.jdbc.api.impl.arrow with parameters of type StatementIdModifierConstructorDescriptionprotectedAbstractArrowResultChunk(long numRows, long rowOffset, long chunkIndex, StatementId statementId, ChunkStatus initialStatus, ExternalLink chunkLink, Instant expiryTime, int chunkReadyTimeoutSeconds) protectedAbstractRemoteChunkProvider(StatementId statementId, ResultManifest resultManifest, ResultData resultData, IDatabricksSession session, IDatabricksHttpClient httpClient, int maxParallelChunkDownloadsPerQuery, CompressionCodec compressionCodec) ArrowResultChunkStateMachine(ChunkStatus initialStatus, long chunkIndex, StatementId statementId) ArrowStreamResult(ResultManifest resultManifest, ResultData resultData, StatementId statementId, IDatabricksSession session) ChunkLinkDownloadService(IDatabricksSession session, StatementId statementId, long totalChunks, ConcurrentMap<Long, T> chunkIndexToChunksMap, long nextBatchStartIndex) -
Uses of StatementId in com.databricks.jdbc.api.impl.arrow.incubator
Methods in com.databricks.jdbc.api.impl.arrow.incubator with parameters of type StatementIdModifier and TypeMethodDescriptionprotected ArrowResultChunkV2RemoteChunkProviderV2.createChunk(StatementId statementId, long chunkIndex, TSparkArrowResultLink resultLink) protected ArrowResultChunkV2RemoteChunkProviderV2.createChunk(StatementId statementId, long chunkIndex, com.databricks.sdk.service.sql.BaseChunkInfo chunkInfo) ArrowResultChunkV2.Builder.withStatementId(StatementId statementId) Constructors in com.databricks.jdbc.api.impl.arrow.incubator with parameters of type StatementIdModifierConstructorDescriptionRemoteChunkProviderV2(StatementId statementId, ResultManifest resultManifest, ResultData resultData, IDatabricksSession session, IDatabricksHttpClient httpClient, int maxParallelChunkDownloadsPerQuery) -
Uses of StatementId in com.databricks.jdbc.api.internal
Methods in com.databricks.jdbc.api.internal that return StatementIdMethods in com.databricks.jdbc.api.internal with parameters of type StatementIdModifier and TypeMethodDescriptionvoidIDatabricksStatementInternal.setStatementId(StatementId statementId) -
Uses of StatementId in com.databricks.jdbc.common.util
Methods in com.databricks.jdbc.common.util with parameters of type StatementIdModifier and TypeMethodDescriptionstatic TOperationHandleDatabricksThriftUtil.getOperationHandle(StatementId statementId) static voidDatabricksThreadContextHolder.setStatementId(StatementId statementId) -
Uses of StatementId in com.databricks.jdbc.dbclient
Methods in com.databricks.jdbc.dbclient with parameters of type StatementIdModifier and TypeMethodDescriptionvoidIDatabricksClient.cancelStatement(StatementId statementId) Cancels a statement in Databricks servervoidIDatabricksClient.closeStatement(StatementId statementId) Closes a statement in Databricks serverIDatabricksClient.getResultChunks(StatementId statementId, long chunkIndex) Fetches the chunk details for given chunk index and statement-Id.IDatabricksClient.getStatementResult(StatementId statementId, IDatabricksSession session, IDatabricksStatementInternal parentStatement) Fetches result for underlying statement-Id -
Uses of StatementId in com.databricks.jdbc.dbclient.impl.common
Methods in com.databricks.jdbc.dbclient.impl.common that return StatementIdModifier and TypeMethodDescriptionstatic StatementIdStatementId.deserialize(String serializedStatementId) Deserializes a StatementId from a serialized stringMethods in com.databricks.jdbc.dbclient.impl.common with parameters of type StatementIdModifier and TypeMethodDescriptionstatic TimeoutHandlerTimeoutHandler.forStatement(int timeoutSeconds, StatementId statementId, IDatabricksClient client) Factory method to create a timeout handler for a databricks client with a statement ID. -
Uses of StatementId in com.databricks.jdbc.dbclient.impl.sqlexec
Methods in com.databricks.jdbc.dbclient.impl.sqlexec with parameters of type StatementIdModifier and TypeMethodDescriptionvoidDatabricksSdkClient.cancelStatement(StatementId typedStatementId) voidDatabricksSdkClient.closeStatement(StatementId typedStatementId) DatabricksSdkClient.getResultChunks(StatementId typedStatementId, long chunkIndex) DatabricksSdkClient.getStatementResult(StatementId typedStatementId, IDatabricksSession session, IDatabricksStatementInternal parentStatement) -
Uses of StatementId in com.databricks.jdbc.dbclient.impl.thrift
Methods in com.databricks.jdbc.dbclient.impl.thrift with parameters of type StatementIdModifier and TypeMethodDescriptionvoidDatabricksThriftServiceClient.cancelStatement(StatementId statementId) voidDatabricksThriftServiceClient.closeStatement(StatementId statementId) DatabricksThriftServiceClient.getResultChunks(StatementId statementId, long chunkIndex) DatabricksThriftServiceClient.getStatementResult(StatementId statementId, IDatabricksSession session, IDatabricksStatementInternal parentStatement) -
Uses of StatementId in com.databricks.jdbc.telemetry
Methods in com.databricks.jdbc.telemetry with parameters of type StatementIdModifier and TypeMethodDescriptionstatic StringTelemetryHelper.getStatementIdString(StatementId statementId) -
Uses of StatementId in com.databricks.jdbc.telemetry.latency
Methods in com.databricks.jdbc.telemetry.latency with parameters of type StatementIdModifier and TypeMethodDescriptionvoidTelemetryCollector.recordTotalChunks(StatementId statementId, long totalChunks) voidTelemetryCollector.setResultFormat(StatementId statementId, com.databricks.sdk.service.sql.Format executionResultFormat)