Fix the logging for pushdown filters (#1419)

kaushikrv42 · web-flow · commit 399e1c6df5d0 · 2025-09-16T23:04:07.000-07:00
* add call and import

* review comment

* review comment

* update log line
diff --git a/bigquery-connector-common/src/main/java/com/google/cloud/bigquery/connector/common/ReadSessionCreator.java b/bigquery-connector-common/src/main/java/com/google/cloud/bigquery/connector/common/ReadSessionCreator.java
@@ -100,7 +100,7 @@ public ReadSessionResponse create(
             + "|selectedFields=[{}],"
             + "|filter=[{}]"
             + "|snapshotTimeMillis[{}]",
-        actualTable.getFriendlyName(),
+        BigQueryUtil.friendlyTableName(table),
         String.join(",", selectedFields),
         filter.orElse("None"),
         config.getSnapshotTimeMillis().isPresent()
diff --git a/spark-bigquery-dsv2/spark-3.1-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/Spark31BigQueryScanBuilder.java b/spark-bigquery-dsv2/spark-3.1-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/Spark31BigQueryScanBuilder.java
@@ -96,8 +96,8 @@ public StructType readSchema() {
   @Override
   public String description() {
     return String.format(
-        "Reading table [%s], Read session Id : %s ",
-        ctx.getFullTableName(), ctx.getReadSessionId());
+        "Reading table [%s], filters [%s], Read session Id : %s ",
+        ctx.getFullTableName(), getPushdownFilters().orElse(""), ctx.getReadSessionId());
   }
 
   @Override
