Skip to content

Commit ec26676

Browse files
committed
refactor(bigquery): import Arrow IPC classes and simplify FQCNs
1 parent 3f91948 commit ec26676

1 file changed

Lines changed: 6 additions & 3 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: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,9 @@
6969
import java.util.concurrent.Callable;
7070
import java.util.regex.Matcher;
7171
import java.util.regex.Pattern;
72+
import org.apache.arrow.vector.ipc.ReadChannel;
73+
import org.apache.arrow.vector.ipc.message.MessageSerializer;
74+
import org.apache.arrow.vector.util.ByteArrayReadableSeekableByteChannel;
7275
import org.checkerframework.checker.nullness.qual.NonNull;
7376

7477
final class BigQueryImpl extends BaseService<BigQueryOptions> implements BigQuery {
@@ -2231,9 +2234,9 @@ public com.google.api.services.bigquery.model.QueryResponse call()
22312234
isArrow = true;
22322235
try {
22332236
arrowSchemaPojo =
2234-
org.apache.arrow.vector.ipc.message.MessageSerializer.deserializeSchema(
2235-
new org.apache.arrow.vector.ipc.ReadChannel(
2236-
new org.apache.arrow.vector.util.ByteArrayReadableSeekableByteChannel(
2237+
MessageSerializer.deserializeSchema(
2238+
new ReadChannel(
2239+
new ByteArrayReadableSeekableByteChannel(
22372240
results.getArrowSchema().decodeSerializedSchema())));
22382241
schema = ArrowDeserializer.arrowSchemaToBigQuerySchema(arrowSchemaPojo);
22392242
} catch (IOException e) {

0 commit comments

Comments
 (0)