SolrReader.java 文件源码

@Override
public boolean next(LongWritable keyHolder, MapWritable valueHolder)
        throws IOException {
    if (StringUtils.isBlank(facetMapping)) {
        SolrDocument doc = cursor.nextDocument();
        if (doc == null) {
            return false;
        }
        keyHolder.set(pos++);
        Object[] values = new Object[solrColumns.length];
        for (int i = 0; i < solrColumns.length; i++) {
            values[i] = doc.getFieldValue(solrColumns[i]);
        }
        setValueHolder(valueHolder, values);
    } else {
        FacetEntry facetEntry = cursor.nextFacetEntry();
        if (facetEntry == null) {
            return false;
        }
        keyHolder.set(pos++);
        setValueHolder(valueHolder, new Object[] { facetEntry.getValue(),
                facetEntry.getCount() });
    }
    return true;
}