@Test public void testReset() throws Exception { BatchIterator bi = new BatchIterator(new FakeRelationalNode(1, new List[] { Arrays.asList(1), Arrays.asList(1), Arrays.asList(1) }, 1)); BufferManager bm = BufferManagerFactory.getStandaloneBufferManager(); bi.setBuffer(bm.createTupleBuffer(Arrays.asList(new ElementSymbol("x", null, DataTypeManager.DefaultDataClasses.INTEGER)), "test", TupleSourceType.PROCESSOR), true); bi.mark(); bi.nextTuple(); bi.nextTuple(); bi.reset(); bi.nextTuple(); }
@Override public void reset() { super.reset(); if (this.buffer != null) { mark = false; return; } }
BatchIterator extends AbstractTupleSource { @Override public void reset() { super.reset(); if (this.buffer != null) { mark = false; return; } } }
BatchIterator extends AbstractTupleSource { @Override public void reset() { super.reset(); if (this.buffer != null) { mark = false; return; } } BatchIterator(BatchProducer source); }
BatchIterator extends AbstractTupleSource { @Override public void reset() { super.reset(); if (this.buffer != null) { mark = false; return; } } BatchIterator(BatchProducer source); long available(); void setBuffer(TupleBuffer buffer, boolean saveOnMark); @Override void closeSource(); @Override void reset(); @Override void mark(); @Override void setPosition(long position); boolean ensureSave(); void disableSave(); void readAhead(long limit); TupleBuffer getBuffer(); }
BatchIterator extends AbstractTupleSource { @Override public void reset() { super.reset(); if (this.buffer != null) { mark = false; return; } } BatchIterator(BatchProducer source); long available(); void setBuffer(TupleBuffer buffer, boolean saveOnMark); @Override void closeSource(); @Override void reset(); @Override void mark(); @Override void setPosition(long position); boolean ensureSave(); void disableSave(); void readAhead(long limit); TupleBuffer getBuffer();  }