@Test public void testGetCurrentValue() throws Throwable { KafkaInputRecordReader kafkaInputRecordReader = new KafkaInputRecordReader(); kafkaInputRecordReader.nextKeyValue(); assertEquals(0, kafkaInputRecordReader.getCurrentValue().getBytes().length); }
@Override public BytesWritable getCurrentValue() throws IOException, InterruptedException { return value; }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public BytesWritable getCurrentValue() throws IOException, InterruptedException { return value; } }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public BytesWritable getCurrentValue() throws IOException, InterruptedException { return value; }  }
KafkaInputRecordReader extends RecordReader<LongWritable, BytesWritable> { @Override public BytesWritable getCurrentValue() throws IOException, InterruptedException { return value; }  @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 BytesWritable getCurrentValue() throws IOException, InterruptedException { return value; }  @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; }