public static ReadAll readAll() {
    return new ReadAll();
  }
@Test
  public void testReadAll() throws Exception {
    SolrIOTestUtils.insertTestDocuments(SOLR_COLLECTION, NUM_DOCS, solrClient);

    PCollection<SolrDocument> output =
        pipeline
            .apply(
                Create.of(
                    SolrIO.read()
                        .withConnectionConfiguration(connectionConfiguration)
                        .from(SOLR_COLLECTION)
                        .withBatchSize(101)))
            .apply(SolrIO.readAll());
    PAssert.thatSingleton(output.apply("Count", Count.globally())).isEqualTo(NUM_DOCS);
    pipeline.run();
  }