SSTableRecordReader.java 文件源码

@Override
public boolean next(MapWritable key, MapWritable value) throws IOException {
    // if we're starting out
    if (hiveRowIterator == null)
        hiveRowIterator = new HiveRowIterator(startPosition, endPosition, partitioner, keyAliasNames, columnAliasNames, metadata, columnNames, rateLimiter);

    if (!hiveRowIterator.hasNext())
        return false;

    Pair<MapWritable, MapWritable> nextPair = hiveRowIterator.next();

    key.clear();
    key.putAll(nextPair.left);
    value.clear();
    value.putAll(nextPair.right);

    return true;
}