Skip to content

Commit ae48147

Browse files
committed
Pull repeated computation outside loop in BigQuerySplitManager
1 parent 744eb72 commit ae48147

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/BigQuerySplitManager.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,8 +156,9 @@ private List<BigQuerySplit> readFromBigQuery(ConnectorSession session, TableDefi
156156
}
157157
ReadSession readSession = createReadSession(session, remoteTableId, ImmutableList.copyOf(projectedColumnsNames), filter, actualParallelism);
158158

159+
String schemaString = getSchemaAsString(readSession);
159160
return readSession.getStreamsList().stream()
160-
.map(stream -> BigQuerySplit.forStream(stream.getName(), getSchemaAsString(readSession), columns, OptionalInt.of(stream.getSerializedSize())))
161+
.map(stream -> BigQuerySplit.forStream(stream.getName(), schemaString, columns, OptionalInt.of(stream.getSerializedSize())))
161162
.collect(toImmutableList());
162163
}
163164

0 commit comments

Comments
 (0)