@Test public void testSkip() throws CollectionException, IOException, ResourceInitializationException { FakeStreamCollectionReader r = new FakeStreamCollectionReader(); r.setSkipDocuments(8); r.doInitialize(null); assertTrue(r.doHasNext()); r.doGetNext(null); assertTrue(r.doHasNext()); r.doGetNext(null); assertFalse(r.doHasNext()); }
protected void setSkipDocuments(int skipDocuments) { this.skipDocuments = skipDocuments; }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setSkipDocuments(int skipDocuments) { this.skipDocuments = skipDocuments; } }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setSkipDocuments(int skipDocuments) { this.skipDocuments = skipDocuments; }  }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setSkipDocuments(int skipDocuments) { this.skipDocuments = skipDocuments; }   }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setSkipDocuments(int skipDocuments) { this.skipDocuments = skipDocuments; }   static final String KEY_MAX_DOCUMENTS; static final String KEY_SKIP_DOCUMENTS; }