Add BigQueryEmulatorContainer

modules/gcloud/build.gradle

@@ -4,6 +4,7 @@ dependencies {
     api project(':testcontainers')
 
     testImplementation platform("com.google.cloud:libraries-bom:26.18.0")
+    testImplementation 'com.google.cloud:google-cloud-bigquery'
     testImplementation 'com.google.cloud:google-cloud-datastore'
     testImplementation 'com.google.cloud:google-cloud-firestore'
     testImplementation 'com.google.cloud:google-cloud-pubsub'

modules/gcloud/src/main/java/org/testcontainers/containers/BigQueryEmulatorContainer.java

@@ -0,0 +1,30 @@
+package org.testcontainers.containers;
+
+import org.testcontainers.utility.DockerImageName;
+
+/**
+ * Testcontainers implementation for BigQuery.
+ */
+public class BigQueryEmulatorContainer extends GenericContainer<BigQueryEmulatorContainer> {
+
+    private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("ghcr.io/goccy/bigquery-emulator");
+
+    private static final int HTTP_PORT = 9050;
+
+    private static final int GRPC_PORT = 9060;
+
+    public BigQueryEmulatorContainer(String image) {
+        this(DockerImageName.parse(image));
+    }
+
+    public BigQueryEmulatorContainer(DockerImageName dockerImageName) {
+        super(dockerImageName);
+        dockerImageName.assertCompatibleWith(DEFAULT_IMAGE_NAME);
+        addExposedPorts(HTTP_PORT, GRPC_PORT);
+        withCommand("--project", "test");
+    }
+
+    public String getEmulatorHttpEndpoint() {
+        return getHost() + ":" + getMappedPort(HTTP_PORT);
+    }
+}

modules/gcloud/src/test/java/org/testcontainers/containers/BigQueryEmulatorContainerTest.java

@@ -0,0 +1,52 @@
+package org.testcontainers.containers;
+
+import com.google.cloud.bigquery.BigQuery;
+import com.google.cloud.bigquery.BigQueryOptions;
+import com.google.cloud.bigquery.DatasetInfo;
+import com.google.cloud.bigquery.QueryJobConfiguration;
+import com.google.cloud.bigquery.TableResult;
+import org.junit.Test;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class BigQueryEmulatorContainerTest {
+
+    @Test
+    public void test() throws Exception {
+        try (
+            BigQueryEmulatorContainer container = new BigQueryEmulatorContainer("ghcr.io/goccy/bigquery-emulator:0.4.3")
+        ) {
+            container.start();
+
+            String url = String.format("http://%s", container.getEmulatorHttpEndpoint());
+            BigQueryOptions options = BigQueryOptions
+                .newBuilder()
+                .setProjectId("test")
+                .setHost(url)
+                .setLocation(url)
+                .build();
+            BigQuery bigQuery = options.getService();
+
+            DatasetInfo datasetInfo = DatasetInfo.newBuilder("testds").build();
+            bigQuery.create(datasetInfo);
+
+            String fn =
+                "CREATE FUNCTION test.testds.testr(arr ARRAY<STRUCT<name STRING, val INT64>>) AS ((SELECT SUM(IF(elem.name = \"foo\",elem.val,null)) FROM UNNEST(arr) AS elem))";
+
+            bigQuery.query(QueryJobConfiguration.newBuilder(fn).build());
+
+            String sql =
+                "SELECT test.testds.testr([STRUCT<name STRING, val INT64>(\"foo\", 10), STRUCT<name STRING, val INT64>(\"bar\", 40), STRUCT<name STRING, val INT64>(\"foo\", 20)])";
+            TableResult result = bigQuery.query(QueryJobConfiguration.newBuilder(sql).build());
+            List<BigDecimal> values = result
+                .streamValues()
+                .map(fieldValues -> fieldValues.get(0).getNumericValue())
+                .collect(Collectors.toList());
+            assertThat(values).containsOnly(BigDecimal.valueOf(30));
+        }
+    }
+}