Skip to content

Commit fe03b35

Browse files
committed
Format imports and add Changes log.
1 parent 75a5558 commit fe03b35

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

CHANGES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
## Next
44
* Added new connector, `spark-4.1-bigquery` aimed to be used in Spark 4.1. Like Spark 4.1, this connector requires at
55
least Java 17 runtime. It is currently in preview mode.
6+
* PR #1445: Add streaming support for Spark DS v2 indirect write.
67

78
## 0.43.1 - 2025-10-22
89
* Issue #1417: Fixed ClassCastException in AWS federated identity

spark-bigquery-connector-common/src/test/java/com/google/cloud/spark/bigquery/integration/WriteIntegrationTestBase.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,12 @@
8181
import org.apache.spark.ml.feature.VectorAssembler;
8282
import org.apache.spark.ml.linalg.SQLDataTypes;
8383
import org.apache.spark.package$;
84-
import org.apache.spark.sql.*;
84+
import org.apache.spark.sql.Dataset;
85+
import org.apache.spark.sql.Encoder;
86+
import org.apache.spark.sql.Encoders;
87+
import org.apache.spark.sql.Row;
88+
import org.apache.spark.sql.RowFactory;
89+
import org.apache.spark.sql.SaveMode;
8590
import org.apache.spark.sql.execution.streaming.MemoryStream;
8691
import org.apache.spark.sql.streaming.OutputMode;
8792
import org.apache.spark.sql.streaming.StreamingQuery;

0 commit comments

Comments
 (0)