@Test public void testGetCurrentKey() throws Throwable { KafkaInputRecordReader kafkaInputRecordReader = new KafkaInputRecordReader(); kafkaInputRecordReader.nextKeyValue(); assertEquals(0L, kafkaInputRecordReader.getCurrentKey().get()); }
@Override public LongWritable getCurrentKey() throws IOException, InterruptedException { return key; }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public LongWritable getCurrentKey() throws IOException, InterruptedException { return key; } }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public LongWritable getCurrentKey() throws IOException, InterruptedException { return key; }  }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public LongWritable getCurrentKey() throws IOException, InterruptedException { return key; }  @Override void initialize(InputSplit split, TaskAttemptContext context); void initialize(InputSplit split, Configuration conf); @Override boolean nextKeyValue(); @Override LongWritable getCurrentKey(); @Override BytesWritable getCurrentValue(); @Override float getProgress(); @Override void close(); }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public LongWritable getCurrentKey() throws IOException, InterruptedException { return key; }  @Override void initialize(InputSplit split, TaskAttemptContext context); void initialize(InputSplit split, Configuration conf); @Override boolean nextKeyValue(); @Override LongWritable getCurrentKey(); @Override BytesWritable getCurrentValue(); @Override float getProgress(); @Override void close(); static final long DEFAULT_KAFKA_CONSUMER_POLL_TIMEOUT; }