File tree Expand file tree Collapse file tree 1 file changed +7
-4
lines changed
spark-bigquery-dsv2/spark-3.5-bigquery/src/test/java/com/google/cloud/spark/bigquery/integration Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change 2323import com .google .cloud .bigquery .Table ;
2424import com .google .cloud .bigquery .TableId ;
2525import java .util .List ;
26-
27- import org .apache .spark .sql .Dataset ;
2826import org .apache .spark .sql .Row ;
2927import org .apache .spark .sql .SparkSession ;
3028import org .junit .After ;
3129import org .junit .Before ;
3230import org .junit .ClassRule ;
31+ import org .junit .Ignore ;
3332import org .junit .Test ;
3433
3534public class CatalogIntegrationTest {
@@ -119,11 +118,13 @@ private void internalTestCreateTableAsSelect(String dataset) throws InterruptedE
119118 }
120119
121120 @ Test
121+ @ Ignore ("unsupported" )
122122 public void testCreateTableWithExplicitTargetInDefaultNamespace () throws Exception {
123123 internalTestCreateTableWithExplicitTarget (DEFAULT_NAMESPACE );
124124 }
125125
126126 @ Test
127+ @ Ignore ("unsupported" )
127128 public void testCreateTableWithExplicitTargetInCustomNamespace () throws Exception {
128129 internalTestCreateTableWithExplicitTarget (testDataset .testDataset );
129130 }
@@ -136,8 +137,10 @@ private void internalTestCreateTableWithExplicitTarget(String dataset)
136137 "CREATE TABLE "
137138 + fullTableName (dataset )
138139 + " OPTIONS (table='bigquery-public-data.samples.shakespeare')" );
139- List <Row > result = spark .sql (
140- "SELECT word, SUM(word_count) FROM "
140+ List <Row > result =
141+ spark
142+ .sql (
143+ "SELECT word, SUM(word_count) FROM "
141144 + fullTableName (dataset )
142145 + " WHERE word='spark' GROUP BY word;" )
143146 .collectAsList ();
You can’t perform that action at this time.
0 commit comments