GsonRecordReader extends RecordReader<LongWritable, JsonObject> { @Override public LongWritable getCurrentKey() { return currentKey; }  @Override void initialize(InputSplit genericSplit, TaskAttemptContext context); @Override boolean nextKeyValue(); @Override LongWritable getCurrentKey(); @Override JsonObject getCurrentValue(); @Override float getProgress(); @Override void close();  }
@Test public void testGetCurrentKey() throws Exception { GsonRecordReader multipleRecordReader = getRecordReader(60); assertThat(multipleRecordReader.nextKeyValue()).isTrue(); assertThat(multipleRecordReader.getCurrentKey()).isEqualTo(key1); assertThat(multipleRecordReader.nextKeyValue()).isTrue(); assertThat(multipleRecordReader.getCurrentKey()).isEqualTo(key2); assertThat(multipleRecordReader.nextKeyValue()).isFalse(); assertThat(multipleRecordReader.getCurrentKey()).isEqualTo(key2); multipleRecordReader.close(); }