public static <T> Read<T> read() {
    return new AutoValue_CassandraIO_Read.Builder<T>().build();
  }
@Test
  public void testWrapAroundRingRanges() throws Exception {
    PCollection<SimpleData> simpledataPCollection =
        pipeline.apply(
            CassandraIO.<SimpleData>read()
                .withHosts(Collections.singletonList(CASSANDRA_HOST))
                .withPort(cassandraPort)
                .withKeyspace(CASSANDRA_KEYSPACE)
                .withTable(CASSANDRA_TABLE_SIMPLEDATA)
                .withMinNumberOfSplits(50)
                .withCoder(SerializableCoder.of(SimpleData.class))
                .withEntity(SimpleData.class));
    PCollection<Long> countPCollection = simpledataPCollection.apply("counting", Count.globally());
    PAssert.that(countPCollection)
        .satisfies(
            i -> {
              long total = 0;
              for (Long aLong : i) {
                total = total + aLong;
              }
              assertEquals(100, total);
              return null;
            });
    pipeline.run();
  }