public static <T> Read<T> read(Class<T> classType) {
    return new AutoValue_CosmosIO_Read.Builder<T>().setClassType(classType).build();
  }
@Test
  public void testRead() {
    PCollection<Family> output =
        pipeline.apply(
            CosmosIO.read(Family.class)
                .withContainer(CONTAINER)
                .withDatabase(DATABASE)
                .withCoder(SerializableCoder.of(Family.class)));

    PAssert.thatSingleton(output.apply("Count", Count.globally())).isEqualTo(4L);
    pipeline.run();
  }