Skip to content

Commit 002311e

Browse files
committed
nit chore
1 parent c509a4a commit 002311e

1 file changed

Lines changed: 3 additions & 5 deletions

File tree

java-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryDatabaseMetaData.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3402,13 +3402,9 @@ public ResultSet getSchemas(String catalog, String schemaPattern) throws SQLExce
34023402
final Schema resultSchema = defineGetSchemasSchema();
34033403
final FieldList resultSchemaFields = resultSchema.getFields();
34043404

3405-
final BlockingQueue<BigQueryFieldValueListWrapper> queue =
3406-
(catalog != null)
3407-
? new LinkedBlockingQueue<>()
3408-
: new LinkedBlockingQueue<>(DEFAULT_QUEUE_CAPACITY);
3409-
34103405
if (catalog != null) {
34113406
// Single-Catalog Path: completely synchronous on caller thread
3407+
final BlockingQueue<BigQueryFieldValueListWrapper> queue = new LinkedBlockingQueue<>();
34123408
List<Dataset> datasets = fetchMatchingDatasets(catalog, schemaPattern, schemaRegex);
34133409
List<FieldValueList> collectedResults = new ArrayList<>();
34143410
for (Dataset dataset : datasets) {
@@ -3422,6 +3418,8 @@ public ResultSet getSchemas(String catalog, String schemaPattern) throws SQLExce
34223418
}
34233419

34243420
// Multi-Catalog Path: fan out using connection-scoped metadataExecutor
3421+
final BlockingQueue<BigQueryFieldValueListWrapper> queue =
3422+
new LinkedBlockingQueue<>(DEFAULT_QUEUE_CAPACITY);
34253423
Runnable multiSchemaFetcher =
34263424
() -> {
34273425
final FieldList localResultSchemaFields = resultSchemaFields;

0 commit comments

Comments
 (0)