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

    BoundedCosmosBDSource<Family> initialSource = new BoundedCosmosBDSource<>(read);
    // Cosmos DB precision is in KB. Inserted test data is ~3KB
    long estimatedSize = initialSource.getEstimatedSizeBytes(pipelineOptions);
    assertEquals("Wrong estimated size", 3072, estimatedSize);
  }