@Override
  public void rewind()
      throws IOException {
    _inputStream.close();
    init();
  }
@Test
  public void testRecordReader()
      throws Exception {
    checkValue(_recordReader, _records, _primaryKeys);
    _recordReader.rewind();
    checkValue(_recordReader, _records, _primaryKeys);
  }