Skip to content

Commit 5f98818

Browse files
Neenu1995Neenu1995
committed
change fine logs to info
1 parent 1a91957 commit 5f98818

1 file changed

Lines changed: 44 additions & 44 deletions

File tree

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

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -960,7 +960,7 @@ private ResultSet getProceduresImpl(
960960
apiExecutor = Executors.newFixedThreadPool(API_EXECUTOR_POOL_SIZE);
961961
routineProcessorExecutor = Executors.newFixedThreadPool(this.metadataFetchThreadCount);
962962

963-
LOG.fine("Submitting parallel findMatchingRoutines tasks...");
963+
LOG.info("Submitting parallel findMatchingRoutines tasks...");
964964
for (Dataset dataset : datasetsToScan) {
965965
if (Thread.currentThread().isInterrupted()) {
966966
LOG.warning("Fetcher interrupted during dataset iteration submission.");
@@ -987,10 +987,10 @@ private ResultSet getProceduresImpl(
987987
Future<List<Routine>> apiFuture = apiExecutor.submit(apiCallable);
988988
apiFutures.add(apiFuture);
989989
}
990-
LOG.fine("Finished submitting " + apiFutures.size() + " findMatchingRoutines tasks.");
990+
LOG.info("Finished submitting " + apiFutures.size() + " findMatchingRoutines tasks.");
991991
apiExecutor.shutdown();
992992

993-
LOG.fine("Processing results from findMatchingRoutines tasks...");
993+
LOG.info("Processing results from findMatchingRoutines tasks...");
994994
for (Future<List<Routine>> apiFuture : apiFutures) {
995995
if (Thread.currentThread().isInterrupted()) {
996996
LOG.warning("Fetcher interrupted while processing API futures.");
@@ -1003,7 +1003,7 @@ private ResultSet getProceduresImpl(
10031003
if (Thread.currentThread().isInterrupted()) break;
10041004

10051005
if ("PROCEDURE".equalsIgnoreCase(routine.getRoutineType())) {
1006-
LOG.fine(
1006+
LOG.info(
10071007
"Submitting processing task for procedure: " + routine.getRoutineId());
10081008
final Routine finalRoutine = routine;
10091009
Future<?> processFuture =
@@ -1032,7 +1032,7 @@ private ResultSet getProceduresImpl(
10321032
}
10331033
}
10341034

1035-
LOG.fine(
1035+
LOG.info(
10361036
"Finished submitting "
10371037
+ processingTaskFutures.size()
10381038
+ " processProcedureInfo tasks.");
@@ -1042,9 +1042,9 @@ private ResultSet getProceduresImpl(
10421042
"Fetcher interrupted before waiting for processing tasks; cancelling remaining.");
10431043
processingTaskFutures.forEach(f -> f.cancel(true));
10441044
} else {
1045-
LOG.fine("Waiting for processProcedureInfo tasks to complete...");
1045+
LOG.info("Waiting for processProcedureInfo tasks to complete...");
10461046
waitForTasksCompletion(processingTaskFutures);
1047-
LOG.fine("All processProcedureInfo tasks completed or handled.");
1047+
LOG.info("All processProcedureInfo tasks completed or handled.");
10481048
}
10491049

10501050
if (!Thread.currentThread().isInterrupted()) {
@@ -1124,7 +1124,7 @@ void processProcedureInfo(
11241124
Routine routine, List<FieldValueList> collectedResults, FieldList resultSchemaFields) {
11251125

11261126
RoutineId routineId = routine.getRoutineId();
1127-
LOG.fine("Processing procedure info for: " + routineId);
1127+
LOG.info("Processing procedure info for: " + routineId);
11281128

11291129
try {
11301130
if (!"PROCEDURE".equalsIgnoreCase(routine.getRoutineType())) {
@@ -1158,7 +1158,7 @@ void processProcedureInfo(
11581158
FieldValueList rowFvl = FieldValueList.of(values, resultSchemaFields);
11591159
collectedResults.add(rowFvl);
11601160

1161-
LOG.fine("Processed and added procedure info row for: " + routineId);
1161+
LOG.info("Processed and added procedure info row for: " + routineId);
11621162

11631163
} catch (Exception e) {
11641164
LOG.warning(
@@ -1299,13 +1299,13 @@ private ResultSet getProcedureColumnsImpl(
12991299
+ catalogParam);
13001300
processingTaskFutures.forEach(f -> f.cancel(true));
13011301
} else {
1302-
LOG.fine(
1302+
LOG.info(
13031303
"Fetcher: Waiting for "
13041304
+ processingTaskFutures.size()
13051305
+ " argument processing tasks. Catalog: "
13061306
+ catalogParam);
13071307
waitForTasksCompletion(processingTaskFutures);
1308-
LOG.fine(
1308+
LOG.info(
13091309
"Fetcher: All argument processing tasks completed or handled. Catalog: "
13101310
+ catalogParam);
13111311
}
@@ -1354,7 +1354,7 @@ private ResultSet getProcedureColumnsImpl(
13541354
private List<Dataset> fetchMatchingDatasetsForProcedureColumns(
13551355
String catalogParam, String schemaPattern, Pattern schemaRegex) throws InterruptedException {
13561356
LOG.finest("++enter++");
1357-
LOG.fine(
1357+
LOG.info(
13581358
"Fetching matching datasets for catalog '%s', schemaPattern '%s'",
13591359
catalogParam, schemaPattern);
13601360
List<Dataset> datasetsToScan =
@@ -1381,7 +1381,7 @@ List<RoutineId> listMatchingProcedureIdsFromDatasets(
13811381
throws InterruptedException {
13821382
LOG.finest("++enter++");
13831383

1384-
LOG.fine(
1384+
LOG.info(
13851385
"Listing matching procedure IDs from %d datasets for catalog '%s'.",
13861386
datasetsToScan.size(), catalogParam);
13871387
final List<Future<List<Routine>>> listRoutineFutures = new ArrayList<>();
@@ -1412,7 +1412,7 @@ List<RoutineId> listMatchingProcedureIdsFromDatasets(
14121412
procedureNameRegex);
14131413
listRoutineFutures.add(listRoutinesExecutor.submit(listCallable));
14141414
}
1415-
LOG.fine(
1415+
LOG.info(
14161416
"Submitted "
14171417
+ listRoutineFutures.size()
14181418
+ " routine list tasks for catalog: "
@@ -1461,7 +1461,7 @@ List<Routine> fetchFullRoutineDetailsForIds(
14611461
List<RoutineId> procedureIdsToGet, ExecutorService getRoutineDetailsExecutor)
14621462
throws InterruptedException {
14631463
LOG.finest("++enter++");
1464-
LOG.fine("Fetching full details for %d procedure IDs.", procedureIdsToGet.size());
1464+
LOG.info("Fetching full details for %d procedure IDs.", procedureIdsToGet.size());
14651465
final List<Future<Routine>> getRoutineFutures = new ArrayList<>();
14661466
final List<Routine> fullRoutines = Collections.synchronizedList(new ArrayList<>());
14671467

@@ -1488,7 +1488,7 @@ List<Routine> fetchFullRoutineDetailsForIds(
14881488
};
14891489
getRoutineFutures.add(getRoutineDetailsExecutor.submit(getCallable));
14901490
}
1491-
LOG.fine("Submitted " + getRoutineFutures.size() + " getRoutine detail tasks.");
1491+
LOG.info("Submitted " + getRoutineFutures.size() + " getRoutine detail tasks.");
14921492

14931493
for (Future<Routine> getFuture : getRoutineFutures) {
14941494
if (Thread.currentThread().isInterrupted()) {
@@ -1521,7 +1521,7 @@ void submitProcedureArgumentProcessingJobs(
15211521
ExecutorService processArgsExecutor,
15221522
List<Future<?>> outArgumentProcessingFutures)
15231523
throws InterruptedException {
1524-
LOG.fine("Submitting argument processing jobs for %d routines.", fullRoutines.size());
1524+
LOG.info("Submitting argument processing jobs for %d routines.", fullRoutines.size());
15251525

15261526
for (Routine fullRoutine : fullRoutines) {
15271527
if (Thread.currentThread().isInterrupted()) {
@@ -1551,7 +1551,7 @@ void submitProcedureArgumentProcessingJobs(
15511551
}
15521552
}
15531553
}
1554-
LOG.fine(
1554+
LOG.info(
15551555
"Finished submitting "
15561556
+ outArgumentProcessingFutures.size()
15571557
+ " processProcedureArguments tasks.");
@@ -1638,7 +1638,7 @@ void processProcedureArguments(
16381638
}
16391639

16401640
if (arguments == null || arguments.isEmpty()) {
1641-
LOG.fine("Procedure " + routineId + " has no arguments.");
1641+
LOG.info("Procedure " + routineId + " has no arguments.");
16421642
return;
16431643
}
16441644

@@ -1920,7 +1920,7 @@ private ResultSet getTablesImpl(
19201920
apiExecutor = Executors.newFixedThreadPool(API_EXECUTOR_POOL_SIZE);
19211921
tableProcessorExecutor = Executors.newFixedThreadPool(this.metadataFetchThreadCount);
19221922

1923-
LOG.fine("Submitting parallel findMatchingTables tasks...");
1923+
LOG.info("Submitting parallel findMatchingTables tasks...");
19241924
for (Dataset dataset : datasetsToScan) {
19251925
if (Thread.currentThread().isInterrupted()) {
19261926
LOG.warning("Table fetcher interrupted during dataset iteration.");
@@ -1947,10 +1947,10 @@ private ResultSet getTablesImpl(
19471947
Future<List<Table>> apiFuture = apiExecutor.submit(apiCallable);
19481948
apiFutures.add(apiFuture);
19491949
}
1950-
LOG.fine("Finished submitting " + apiFutures.size() + " findMatchingTables tasks.");
1950+
LOG.info("Finished submitting " + apiFutures.size() + " findMatchingTables tasks.");
19511951
apiExecutor.shutdown();
19521952

1953-
LOG.fine("Processing results from findMatchingTables tasks...");
1953+
LOG.info("Processing results from findMatchingTables tasks...");
19541954
for (Future<List<Table>> apiFuture : apiFutures) {
19551955
if (Thread.currentThread().isInterrupted()) {
19561956
LOG.warning("Table fetcher interrupted while processing API futures.");
@@ -1989,17 +1989,17 @@ private ResultSet getTablesImpl(
19891989
}
19901990
}
19911991

1992-
LOG.fine(
1992+
LOG.info(
19931993
"Finished submitting " + processingFutures.size() + " processTableInfo tasks.");
19941994

19951995
if (Thread.currentThread().isInterrupted()) {
19961996
LOG.warning(
19971997
"Fetcher interrupted before waiting for processing tasks; cancelling remaining.");
19981998
processingFutures.forEach(f -> f.cancel(true));
19991999
} else {
2000-
LOG.fine("Waiting for processTableInfo tasks to complete...");
2000+
LOG.info("Waiting for processTableInfo tasks to complete...");
20012001
waitForTasksCompletion(processingFutures);
2002-
LOG.fine("All processTableInfo tasks completed.");
2002+
LOG.info("All processTableInfo tasks completed.");
20032003
}
20042004

20052005
if (!Thread.currentThread().isInterrupted()) {
@@ -2086,7 +2086,7 @@ void processTableInfo(
20862086
FieldList resultSchemaFields) {
20872087

20882088
TableId tableId = table.getTableId();
2089-
LOG.fine("Processing table info for: " + tableId);
2089+
LOG.info("Processing table info for: " + tableId);
20902090

20912091
try {
20922092
String catalogName = tableId.getProject();
@@ -2118,7 +2118,7 @@ void processTableInfo(
21182118
FieldValueList rowFvl = FieldValueList.of(values, resultSchemaFields);
21192119
collectedResults.add(rowFvl);
21202120

2121-
LOG.fine("Processed and added table info row for: " + tableId);
2121+
LOG.info("Processed and added table info row for: " + tableId);
21222122
} catch (Exception e) {
21232123
LOG.warning(
21242124
"Error processing table info for %s: %s. Skipping this table.", tableId, e.getMessage());
@@ -2349,7 +2349,7 @@ private ResultSet getColumnsImpl(
23492349
}
23502350

23512351
TableId tableId = table.getTableId();
2352-
LOG.fine("Submitting task for table: " + tableId);
2352+
LOG.info("Submitting task for table: " + tableId);
23532353
final Table finalTable = table;
23542354
Future<?> future =
23552355
columnExecutor.submit(
@@ -2402,13 +2402,13 @@ private void processTableColumns(
24022402
FieldList resultSchemaFields) {
24032403
LOG.finest("++enter++");
24042404
TableId tableId = table.getTableId();
2405-
LOG.fine("Processing columns for table: " + tableId);
2405+
LOG.info("Processing columns for table: " + tableId);
24062406
TableDefinition definition = table.getDefinition();
24072407
Schema tableSchema = (definition != null) ? definition.getSchema() : null;
24082408

24092409
try {
24102410
if (tableSchema == null) {
2411-
LOG.fine(
2411+
LOG.info(
24122412
"Schema not included in table object for "
24132413
+ tableId
24142414
+ ", fetching full table details...");
@@ -2450,7 +2450,7 @@ private void processTableColumns(
24502450
FieldValueList rowFvl = FieldValueList.of(values, resultSchemaFields);
24512451
collectedResults.add(rowFvl);
24522452
}
2453-
LOG.fine("Finished processing columns for table: " + tableId);
2453+
LOG.info("Finished processing columns for table: " + tableId);
24542454
} catch (BigQueryException e) {
24552455
LOG.warning(
24562456
"BigQueryException processing table %s: %s (Code: %d)",
@@ -4038,7 +4038,7 @@ private ResultSet getSchemasImpl(String catalog, String schemaPattern) {
40384038
continue;
40394039
}
40404040

4041-
LOG.fine("Processing found datasets for project: " + currentProjectToScan);
4041+
LOG.info("Processing found datasets for project: " + currentProjectToScan);
40424042
for (Dataset dataset : datasetsInProject) {
40434043
if (Thread.currentThread().isInterrupted()) {
40444044
LOG.warning(
@@ -4291,7 +4291,7 @@ private ResultSet getFunctionsImpl(
42914291

42924292
Callable<List<Routine>> apiCallable =
42934293
() -> {
4294-
LOG.fine(
4294+
LOG.info(
42954295
"Fetching all routines for dataset: %s, pattern: %s",
42964296
currentDatasetId.getDataset(), functionNamePattern);
42974297
return findMatchingBigQueryObjects(
@@ -4312,7 +4312,7 @@ private ResultSet getFunctionsImpl(
43124312
Future<List<Routine>> apiFuture = apiExecutor.submit(apiCallable);
43134313
apiFutures.add(apiFuture);
43144314
}
4315-
LOG.fine(
4315+
LOG.info(
43164316
"Finished submitting "
43174317
+ apiFutures.size()
43184318
+ " findMatchingRoutines (for functions) tasks.");
@@ -4333,7 +4333,7 @@ private ResultSet getFunctionsImpl(
43334333
String routineType = routine.getRoutineType();
43344334
if ("SCALAR_FUNCTION".equalsIgnoreCase(routineType)
43354335
|| "TABLE_FUNCTION".equalsIgnoreCase(routineType)) {
4336-
LOG.fine(
4336+
LOG.info(
43374337
"Submitting processing task for function: "
43384338
+ routine.getRoutineId()
43394339
+ " of type "
@@ -4416,7 +4416,7 @@ Schema defineGetFunctionsSchema() {
44164416
void processFunctionInfo(
44174417
Routine routine, List<FieldValueList> collectedResults, FieldList resultSchemaFields) {
44184418
RoutineId routineId = routine.getRoutineId();
4419-
LOG.fine("Processing function info for: " + routineId);
4419+
LOG.info("Processing function info for: " + routineId);
44204420

44214421
try {
44224422
String catalogName = routineId.getProject();
@@ -4445,7 +4445,7 @@ void processFunctionInfo(
44454445

44464446
FieldValueList rowFvl = FieldValueList.of(values, resultSchemaFields);
44474447
collectedResults.add(rowFvl);
4448-
LOG.fine("Processed and added function info row for: " + routineId);
4448+
LOG.info("Processed and added function info row for: " + routineId);
44494449

44504450
} catch (Exception e) {
44514451
LOG.warning(
@@ -4596,13 +4596,13 @@ private ResultSet getFunctionColumnsImpl(
45964596
+ catalogParam);
45974597
processingTaskFutures.forEach(f -> f.cancel(true));
45984598
} else {
4599-
LOG.fine(
4599+
LOG.info(
46004600
"Fetcher: Waiting for "
46014601
+ processingTaskFutures.size()
46024602
+ " parameter processing tasks. Catalog: "
46034603
+ catalogParam);
46044604
waitForTasksCompletion(processingTaskFutures);
4605-
LOG.fine(
4605+
LOG.info(
46064606
"Fetcher: All parameter processing tasks completed or handled. Catalog: "
46074607
+ catalogParam);
46084608
}
@@ -4725,7 +4725,7 @@ List<RoutineId> listMatchingFunctionIdsFromDatasets(
47254725
throws InterruptedException {
47264726
LOG.finest("++enter++");
47274727

4728-
LOG.fine(
4728+
LOG.info(
47294729
"Listing matching function IDs from %d datasets for catalog '%s'.",
47304730
datasetsToScan.size(), catalogParam);
47314731
final List<Future<List<Routine>>> listRoutineFutures = new ArrayList<>();
@@ -4755,7 +4755,7 @@ List<RoutineId> listMatchingFunctionIdsFromDatasets(
47554755
functionNameRegex);
47564756
listRoutineFutures.add(listRoutinesExecutor.submit(listCallable));
47574757
}
4758-
LOG.fine(
4758+
LOG.info(
47594759
"Submitted "
47604760
+ listRoutineFutures.size()
47614761
+ " routine (function) list tasks for catalog: "
@@ -4811,7 +4811,7 @@ void submitFunctionParameterProcessingJobs(
48114811
ExecutorService processParamsExecutor,
48124812
List<Future<?>> outParameterProcessingFutures)
48134813
throws InterruptedException {
4814-
LOG.fine("Submitting parameter processing jobs for %d functions.", fullFunctions.size());
4814+
LOG.info("Submitting parameter processing jobs for %d functions.", fullFunctions.size());
48154815

48164816
for (Routine fullFunction : fullFunctions) {
48174817
if (Thread.currentThread().isInterrupted()) {
@@ -4845,7 +4845,7 @@ void submitFunctionParameterProcessingJobs(
48454845
}
48464846
}
48474847
}
4848-
LOG.fine(
4848+
LOG.info(
48494849
"Finished submitting "
48504850
+ outParameterProcessingFutures.size()
48514851
+ " processFunctionParametersAndReturnValue tasks.");
@@ -5256,7 +5256,7 @@ <T> List<T> findMatchingBigQueryObjects(
52565256
objectTypeName, pattern == null ? "<all>" : pattern);
52575257
Page<T> firstPage = listAllOperation.get();
52585258
objects = firstPage.iterateAll();
5259-
LOG.fine("Retrieved initial %s list, iterating & filtering if needed...", objectTypeName);
5259+
LOG.info("Retrieved initial %s list, iterating & filtering if needed...", objectTypeName);
52605260

52615261
} else {
52625262
LOG.info("Getting specific %s: '%s'", objectTypeName, pattern);

0 commit comments

Comments
 (0)