Skip to content

Commit 2b9ac08

Browse files
Detelin MaslevDetelin Maslev
authored andcommitted
fix transformTableData
1 parent 04ca837 commit 2b9ac08

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2128,7 +2128,7 @@ private static class QueryResponsePageFetcher implements NextPageFetcher<FieldVa
21282128
public Page<FieldValueList> getNextPage() {
21292129
GetQueryResultsResponse response = serviceOptions.getBigQueryRpcV2().getQueryResults(jobId.getProject(), jobId.getJob(), jobId.getLocation(), requestOptions);
21302130
QueryResponsePageFetcher fetcher = new QueryResponsePageFetcher(jobId, serviceOptions, response.getPageToken(), requestOptions);
2131-
return new PageImpl<>(fetcher, response.getPageToken(), transformTableData(response.getRows(), Schema.fromPb(response.getSchema())));
2131+
return new PageImpl<>(fetcher, response.getPageToken(), transformTableData(response.getRows(), Schema.fromPb(response.getSchema()), serviceOptions.getUseInt64Timestamps()));
21322132
}
21332133
}
21342134

@@ -2181,7 +2181,7 @@ public SyncTableResult syncQuery(QueryJobConfiguration configuration, QueryResul
21812181
.setPageNoSchema(new PageImpl<>(
21822182
new QueryResponsePageFetcher(jobId, getOptions(), response.getPageToken(), optionMap),
21832183
response.getPageToken(),
2184-
transformTableData(response.getRows(), Schema.fromPb(response.getSchema()))))
2184+
transformTableData(response.getRows(), Schema.fromPb(response.getSchema()), getOptions().getUseInt64Timestamps())))
21852185
.build();
21862186
}
21872187

0 commit comments

Comments
 (0)