Skip to content

Commit

Permalink
Updated reset
Browse files Browse the repository at this point in the history
  • Loading branch information
nyghtowl committed Mar 9, 2016
1 parent ab69351 commit 0818cb9
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -242,8 +242,11 @@ public int totalOutcomes() {

@Override
public void reset() {
if (recordReader instanceof RecordReader)
if (recordReader instanceof RecordReader){
batchNum = 0;
notOvershot = true;
recordReader.reset();
}
else if (recordReader instanceof SequenceRecordReader)
throw new UnsupportedOperationException("Reset not supported for SequenceRecordReader type.");
}
Expand Down

0 comments on commit 0818cb9

Please sign in to comment.