SolrIO { public static ReadAll readAll() { return new ReadAll(); } private  SolrIO(); static Read read(); static ReadAll readAll(); static Write write();  }
@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(); }