|
3 | 3 | import static com.databricks.jdbc.common.DatabricksJdbcConstants.QUERY_TAGS; |
4 | 4 | import static com.databricks.jdbc.common.util.WildcardUtil.isNullOrEmpty; |
5 | 5 |
|
6 | | -import com.databricks.jdbc.api.impl.DatabricksConnection; |
7 | 6 | import com.databricks.jdbc.api.internal.IDatabricksConnectionContext; |
8 | 7 | import com.databricks.jdbc.api.internal.IDatabricksStatementInternal; |
9 | 8 | import com.databricks.jdbc.common.DatabricksClientConfiguratorManager; |
@@ -484,57 +483,6 @@ public static void setResultFormat( |
484 | 483 | } |
485 | 484 | } |
486 | 485 |
|
487 | | - /** |
488 | | - * Records a result set iteration. Silently ignores errors. |
489 | | - * |
490 | | - * @param connectionContext The connection context |
491 | | - * @param statementId The statement ID |
492 | | - * @param chunkCount The total number of chunks |
493 | | - * @param hasNext Whether there are more rows |
494 | | - */ |
495 | | - public static void recordResultSetIteration( |
496 | | - IDatabricksConnectionContext connectionContext, |
497 | | - String statementId, |
498 | | - long chunkCount, |
499 | | - boolean hasNext) { |
500 | | - try { |
501 | | - if (connectionContext != null) { |
502 | | - TelemetryCollectorManager.getInstance() |
503 | | - .getOrCreateCollector(connectionContext) |
504 | | - .recordResultSetIteration(statementId, chunkCount, hasNext); |
505 | | - } |
506 | | - } catch (Exception e) { |
507 | | - LOGGER.trace("Error recording result set iteration telemetry: {}", e.getMessage()); |
508 | | - } |
509 | | - } |
510 | | - |
511 | | - /** |
512 | | - * Records a result set iteration from a parent statement. Extracts connection context safely and |
513 | | - * silently ignores all errors. |
514 | | - * |
515 | | - * @param parentStatement The parent statement (can be null) |
516 | | - * @param statementId The statement ID |
517 | | - * @param chunkCount The total number of chunks (can be null) |
518 | | - * @param hasNext Whether there are more rows |
519 | | - */ |
520 | | - public static void recordResultSetIteration( |
521 | | - IDatabricksStatementInternal parentStatement, |
522 | | - StatementId statementId, |
523 | | - Long chunkCount, |
524 | | - boolean hasNext) { |
525 | | - try { |
526 | | - if (parentStatement != null && chunkCount != null) { |
527 | | - IDatabricksConnectionContext connectionContext = |
528 | | - ((DatabricksConnection) parentStatement.getStatement().getConnection()) |
529 | | - .getConnectionContext(); |
530 | | - recordResultSetIteration( |
531 | | - connectionContext, statementId.toSQLExecStatementId(), chunkCount, hasNext); |
532 | | - } |
533 | | - } catch (Exception e) { |
534 | | - LOGGER.trace("Error getting connection context for telemetry: {}", e.getMessage()); |
535 | | - } |
536 | | - } |
537 | | - |
538 | 486 | /** |
539 | 487 | * Records get operation status latency. Silently ignores errors. |
540 | 488 | * |
|
0 commit comments