Skip to content

Commit 80ae0af

Browse files
committed
refactor(bigquery): eliminate FQCNs in ArrowSerializationOptionsConverter and BigQueryImpl
1 parent 6c6ffb8 commit 80ae0af

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery

java-bigquery/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
@@ -45,7 +45,6 @@
4545
import com.google.cloud.bigquery.InsertAllRequest.RowToInsert;
4646
import com.google.cloud.bigquery.spi.v2.BigQueryRpc;
4747
import com.google.cloud.bigquery.spi.v2.HttpBigQueryRpc;
48-
import com.google.cloud.bigquery.storage.v1.ArrowRecordBatch;
4948
import com.google.cloud.bigquery.storage.v1.BigQueryReadClient;
5049
import com.google.cloud.bigquery.storage.v1.BigQueryReadSettings;
5150
import com.google.cloud.bigquery.storage.v1.ReadRowsRequest;
@@ -357,7 +356,8 @@ public Page<FieldValueList> getNextPage() {
357356
while (rowBatch.size() < pageSize && streamIterator.hasNext()) {
358357
ReadRowsResponse response = streamIterator.next();
359358
if (response.hasArrowRecordBatch()) {
360-
ArrowRecordBatch batch = response.getArrowRecordBatch();
359+
com.google.cloud.bigquery.storage.v1.ArrowRecordBatch batch =
360+
response.getArrowRecordBatch();
361361
ArrowRecordBatch deserializedBatch =
362362
MessageSerializer.deserializeRecordBatch(
363363
new ReadChannel(

0 commit comments

Comments
 (0)