Skip to content

Commit e9b4453

Browse files
ldetmerldetmer
committed
ran formatter
1 parent dbb05b3 commit e9b4453

2 files changed

Lines changed: 41 additions & 39 deletions

File tree

‎java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/spi/v2/HttpBigQueryRpc.java‎

Lines changed: 38 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ public Dataset getDatasetSkipExceptionTranslation(
193193
"DatasetService",
194194
"GetDataset",
195195
gcpResourceDestinationId,
196-
options),
196+
options),
197197
span -> {
198198
Dataset dataset = bqGetRequest.execute();
199199
if (span != null) {
@@ -238,7 +238,7 @@ public Tuple<String, Iterable<Dataset>> listDatasetsSkipExceptionTranslation(
238238
"DatasetService",
239239
"ListDatasets",
240240
gcpResourceDestinationId,
241-
options),
241+
options),
242242
span -> {
243243
if (span != null) {
244244
span.setAttribute("bq.rpc.page_token", datasetsListRequest.getPageToken());
@@ -296,7 +296,7 @@ public Dataset createSkipExceptionTranslation(Dataset dataset, Map<Option, ?> op
296296
"DatasetService",
297297
"InsertDataset",
298298
gcpResourceDestinationId,
299-
options),
299+
options),
300300
span -> {
301301
Dataset datasetResponse = bqCreateRequest.execute();
302302
if (span != null) {
@@ -349,7 +349,7 @@ public Table createSkipExceptionTranslation(Table table, Map<Option, ?> options)
349349
"TableService",
350350
"InsertTable",
351351
gcpResourceDestinationId,
352-
options),
352+
options),
353353
span -> {
354354
Table tableResponse = bqCreateRequest.execute();
355355
if (span != null) {
@@ -400,7 +400,7 @@ public Routine createSkipExceptionTranslation(Routine routine, Map<Option, ?> op
400400
"RoutineService",
401401
"InsertRoutine",
402402
gcpResourceDestinationId,
403-
options),
403+
options),
404404
span -> {
405405
Routine routineResponse = bqCreateRequest.execute();
406406
if (span != null) {
@@ -446,7 +446,7 @@ public Job createSkipExceptionTranslation(Job job, Map<Option, ?> options) throw
446446
"JobService",
447447
"InsertJob",
448448
gcpResourceDestinationId,
449-
options),
449+
options),
450450
span -> {
451451
Job jobResponse = bqCreateRequest.execute();
452452
if (span != null) {
@@ -489,7 +489,7 @@ public Job createJobForQuerySkipExceptionTranslation(Job job) throws IOException
489489
"JobService",
490490
"InsertJob",
491491
gcpResourceDestinationId,
492-
null),
492+
null),
493493
span -> {
494494
Job jobResponse = bqCreateRequest.execute();
495495
if (span != null) {
@@ -543,7 +543,7 @@ public boolean deleteDatasetSkipExceptionTranslation(
543543
"DatasetService",
544544
"DeleteDataset",
545545
gcpResourceDestinationId,
546-
options),
546+
options),
547547
span -> {
548548
bqDeleteRequest.execute();
549549
return true;
@@ -594,7 +594,7 @@ public Dataset patchSkipExceptionTranslation(Dataset dataset, Map<Option, ?> opt
594594
"DatasetService",
595595
"PatchDataset",
596596
gcpResourceDestinationId,
597-
options),
597+
options),
598598
span -> {
599599
Dataset datasetResponse = bqPatchRequest.execute();
600600
if (span != null) {
@@ -649,7 +649,7 @@ public Table patchSkipExceptionTranslation(Table table, Map<Option, ?> options)
649649
"TableService",
650650
"PatchTable",
651651
gcpResourceDestinationId,
652-
options),
652+
options),
653653
span -> {
654654
Table tableResponse = bqPatchRequest.execute();
655655
if (span != null) {
@@ -706,7 +706,7 @@ public Table getTableSkipExceptionTranslation(
706706
"TableService",
707707
"GetTable",
708708
gcpResourceDestinationId,
709-
options),
709+
options),
710710
span -> {
711711
Table tableResponse = bqGetRequest.execute();
712712
if (span != null) {
@@ -758,7 +758,7 @@ public Tuple<String, Iterable<Table>> listTablesSkipExceptionTranslation(
758758
"TableService",
759759
"ListTables",
760760
gcpResourceDestinationId,
761-
options),
761+
options),
762762
span -> {
763763
if (span != null) {
764764
span.setAttribute("bq.rpc.page_token", tableListRequest.getPageToken());
@@ -832,7 +832,7 @@ public boolean deleteTableSkipExceptionTranslation(
832832
"TableService",
833833
"DeleteTable",
834834
gcpResourceDestinationId,
835-
null),
835+
null),
836836
span -> {
837837
bqDeleteRequest.execute();
838838
return true;
@@ -882,7 +882,7 @@ public Model patchSkipExceptionTranslation(Model model, Map<Option, ?> options)
882882
"ModelService",
883883
"PatchModel",
884884
gcpResourceDestinationId,
885-
options),
885+
options),
886886
span -> {
887887
Model modelResponse = bqPatchRequest.execute();
888888
if (span != null) {
@@ -939,7 +939,7 @@ public Model getModelSkipExceptionTranslation(
939939
"ModelService",
940940
"GetModel",
941941
gcpResourceDestinationId,
942-
options),
942+
options),
943943
span -> {
944944
Model modelResponse = bqGetRequest.execute();
945945
if (span != null) {
@@ -991,7 +991,7 @@ public Tuple<String, Iterable<Model>> listModelsSkipExceptionTranslation(
991991
"ModelService",
992992
"ListModels",
993993
gcpResourceDestinationId,
994-
options),
994+
options),
995995
span -> {
996996
if (span != null) {
997997
span.setAttribute("bq.rpc.page_token", modelListRequest.getPageToken());
@@ -1042,7 +1042,7 @@ public boolean deleteModelSkipExceptionTranslation(
10421042
"ModelService",
10431043
"DeleteModel",
10441044
gcpResourceDestinationId,
1045-
null),
1045+
null),
10461046
span -> {
10471047
bqDeleteRequest.execute();
10481048
return true;
@@ -1094,7 +1094,7 @@ public Routine updateSkipExceptionTranslation(Routine routine, Map<Option, ?> op
10941094
"RoutineService",
10951095
"UpdateRoutine",
10961096
gcpResourceDestinationId,
1097-
options),
1097+
options),
10981098
span -> {
10991099
Routine routineResponse = bqUpdateRequest.execute();
11001100
if (span != null) {
@@ -1151,7 +1151,7 @@ public Routine getRoutineSkipExceptionTranslation(
11511151
"RoutineService",
11521152
"GetRoutine",
11531153
gcpResourceDestinationId,
1154-
options),
1154+
options),
11551155
span -> {
11561156
Routine routineResponse = bqGetRequest.execute();
11571157
if (span != null) {
@@ -1203,7 +1203,7 @@ public Tuple<String, Iterable<Routine>> listRoutinesSkipExceptionTranslation(
12031203
"RoutineService",
12041204
"ListRoutines",
12051205
gcpResourceDestinationId,
1206-
options),
1206+
options),
12071207
span -> {
12081208
if (span != null) {
12091209
span.setAttribute("bq.rpc.page_token", routineListRequest.getPageToken());
@@ -1253,7 +1253,7 @@ public boolean deleteRoutineSkipExceptionTranslation(
12531253
"RoutineService",
12541254
"DeleteRoutine",
12551255
gcpResourceDestinationId,
1256-
null),
1256+
null),
12571257
span -> {
12581258
bqDeleteRequest.execute();
12591259
return true;
@@ -1301,7 +1301,7 @@ public TableDataInsertAllResponse insertAllSkipExceptionTranslation(
13011301
"TableDataService",
13021302
"InsertAll",
13031303
gcpResourceDestinationId,
1304-
null),
1304+
null),
13051305
span -> insertAllRequest.execute());
13061306
}
13071307

@@ -1352,7 +1352,7 @@ public TableDataList listTableDataSkipExceptionTranslation(
13521352
"TableDataService",
13531353
"List",
13541354
gcpResourceDestinationId,
1355-
options),
1355+
options),
13561356
span -> {
13571357
if (span != null) {
13581358
span.setAttribute("bq.rpc.page_token", bqListRequest.getPageToken());
@@ -1413,7 +1413,7 @@ public TableDataList listTableDataWithRowLimitSkipExceptionTranslation(
14131413
"TableDataService",
14141414
"List",
14151415
gcpResourceDestinationId,
1416-
null),
1416+
null),
14171417
span -> {
14181418
if (span != null) {
14191419
span.setAttribute("bq.rpc.page_token", bqListRequest.getPageToken());
@@ -1465,7 +1465,7 @@ public Job getJobSkipExceptionTranslation(
14651465
"JobService",
14661466
"GetJob",
14671467
gcpResourceDestinationId,
1468-
options),
1468+
options),
14691469
span -> {
14701470
Job jobResponse = bqGetRequest.execute();
14711471
if (span != null) {
@@ -1515,7 +1515,7 @@ public Job getQueryJobSkipExceptionTranslation(String projectId, String jobId, S
15151515
"JobService",
15161516
"GetJob",
15171517
gcpResourceDestinationId,
1518-
null),
1518+
null),
15191519
span -> {
15201520
Job jobResponse = bqGetRequest.execute();
15211521
if (span != null) {
@@ -1572,7 +1572,7 @@ public Tuple<String, Iterable<Job>> listJobsSkipExceptionTranslation(
15721572
"JobService",
15731573
"ListJobs",
15741574
gcpResourceDestinationId,
1575-
options),
1575+
options),
15761576
span -> {
15771577
if (span != null) {
15781578
span.setAttribute("bq.rpc.page_token", listJobsRequest.getPageToken());
@@ -1649,7 +1649,7 @@ public boolean cancelSkipExceptionTranslation(String projectId, String jobId, St
16491649
"JobService",
16501650
"CancelJob",
16511651
gcpResourceDestinationId,
1652-
null),
1652+
null),
16531653
span -> {
16541654
bqCancelRequest.execute();
16551655
return true;
@@ -1690,7 +1690,7 @@ public boolean deleteJobSkipExceptionTranslation(
16901690
"JobService",
16911691
"DeleteJob",
16921692
gcpResourceDestinationId,
1693-
null),
1693+
null),
16941694
span -> {
16951695
bqDeleteRequest.execute();
16961696
return true;
@@ -1743,7 +1743,7 @@ public GetQueryResultsResponse getQueryResultsSkipExceptionTranslation(
17431743
"JobService",
17441744
"GetQueryResults",
17451745
gcpResourceDestinationId,
1746-
options),
1746+
options),
17471747
span -> {
17481748
if (span != null) {
17491749
span.setAttribute("bq.rpc.page_token", queryRequest.getPageToken());
@@ -1795,7 +1795,7 @@ public GetQueryResultsResponse getQueryResultsWithRowLimitSkipExceptionTranslati
17951795
"JobService",
17961796
"GetQueryResults",
17971797
gcpResourceDestinationId,
1798-
null),
1798+
null),
17991799
span -> {
18001800
if (span != null) {
18011801
span.setAttribute("bq.rpc.page_token", queryRequest.getPageToken());
@@ -1830,7 +1830,7 @@ public QueryResponse queryRpcSkipExceptionTranslation(String projectId, QueryReq
18301830
"JobService",
18311831
"Query",
18321832
gcpResourceDestinationId,
1833-
null),
1833+
null),
18341834
span -> {
18351835
return queryRequest.execute();
18361836
});
@@ -1960,7 +1960,7 @@ public Policy getIamPolicySkipExceptionTranslation(String resourceId, Map<Option
19601960
"TableService",
19611961
"GetIamPolicy",
19621962
gcpResourceDestinationId,
1963-
options),
1963+
options),
19641964
span -> {
19651965
return bqGetRequest.execute();
19661966
});
@@ -1995,7 +1995,7 @@ public Policy setIamPolicySkipExceptionTranslation(
19951995
"TableService",
19961996
"SetIamPolicy",
19971997
gcpResourceDestinationId,
1998-
options),
1998+
options),
19991999
span -> {
20002000
return bqSetRequest.execute();
20012001
});
@@ -2031,7 +2031,7 @@ public TestIamPermissionsResponse testIamPermissionsSkipExceptionTranslation(
20312031
"TableService",
20322032
"TestIamPermissions",
20332033
gcpResourceDestinationId,
2034-
options),
2034+
options),
20352035
span -> {
20362036
return bqTestRequest.execute();
20372037
});
@@ -2047,7 +2047,7 @@ private Span createRpcTracingSpan(
20472047
String service,
20482048
String method,
20492049
String gcpResourceDestinationId,
2050-
Map<Option, ?> options) {
2050+
Map<Option, ?> options) {
20512051
if (!this.options.isOpenTelemetryTracingEnabled()
20522052
|| this.options.getOpenTelemetryTracer() == null) {
20532053
return null;
@@ -2061,7 +2061,8 @@ private Span createRpcTracingSpan(
20612061
.setAttribute("bq.rpc.service", service)
20622062
.setAttribute("bq.rpc.method", method)
20632063
.setAttribute("bq.rpc.system", "http")
2064-
.setAttribute(BigQueryTelemetryTracer.GCP_RESOURCE_DESTINATION_ID, gcpResourceDestinationId);
2064+
.setAttribute(
2065+
BigQueryTelemetryTracer.GCP_RESOURCE_DESTINATION_ID, gcpResourceDestinationId);
20652066

20662067
if (options != null) {
20672068
builder.setAllAttributes(otelAttributesFromOptions(options));

‎java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/spi/v2/HttpBigQueryRpcTest.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ private void verifySpan(
145145
String service,
146146
String method,
147147
String gcpResourceDestinationId,
148-
Map<String, String> attributes) {
148+
Map<String, String> attributes) {
149149
List<SpanData> spans = spanExporter.getFinishedSpanItems();
150150
assertThat(spans).isNotEmpty();
151151
SpanData rpcSpan =
@@ -156,7 +156,8 @@ private void verifySpan(
156156
assertEquals("http", rpcSpan.getAttributes().get(AttributeKey.stringKey("bq.rpc.system")));
157157

158158
assertEquals(
159-
gcpResourceDestinationId, rpcSpan.getAttributes().get(BigQueryTelemetryTracer.GCP_RESOURCE_DESTINATION_ID));
159+
gcpResourceDestinationId,
160+
rpcSpan.getAttributes().get(BigQueryTelemetryTracer.GCP_RESOURCE_DESTINATION_ID));
160161

161162
if (attributes != null) {
162163
for (Map.Entry<String, String> entry : attributes.entrySet()) {

0 commit comments

Comments
 (0)