public static <T> Write<T> write(String jdbcUrl, String table) {
    return new AutoValue_ClickHouseIO_Write.Builder<T>()
        .jdbcUrl(jdbcUrl)
        .table(table)
        .properties(new Properties())
        .maxInsertBlockSize(DEFAULT_MAX_INSERT_BLOCK_SIZE)
        .initialBackoff(DEFAULT_INITIAL_BACKOFF)
        .maxRetries(DEFAULT_MAX_RETRIES)
        .maxCumulativeBackoff(DEFAULT_MAX_CUMULATIVE_BACKOFF)
        .build()
        .withInsertDeduplicate(true)
        .withInsertDistributedSync(true);
  }
@Test
  public void testArrayOfArrayOfInt64() throws Exception {
    Schema schema =
        Schema.of(Schema.Field.of("f0", FieldType.array(FieldType.array(FieldType.INT64))));
    Row row1 =
        Row.withSchema(schema)
            .addValue(
                Arrays.asList(Arrays.asList(1L, 2L), Arrays.asList(2L, 3L), Arrays.asList(3L, 4L)))
            .build();

    executeSql("CREATE TABLE test_array_of_array_of_int64 (f0 Array(Array(Int64))) ENGINE=Log");

    pipeline
        .apply(Create.of(row1).withRowSchema(schema))
        .apply(write("test_array_of_array_of_int64"));

    pipeline.run().waitUntilFinish();

    long sum0 =
        executeQueryAsLong(
            "SELECT SUM(arraySum(arrayMap(x -> arraySum(x), f0))) "
                + "FROM test_array_of_array_of_int64");

    assertEquals(15L, sum0);
  }