SolrWriter.java 文件源码

@Override
public void write(Writable w) throws IOException {
    MapWritable map = (MapWritable) w;
    SolrInputDocument doc = new SolrInputDocument();
    for (final Map.Entry<Writable, Writable> entry : map.entrySet()) {
        String key = entry.getKey().toString();

        if (entry.getValue() instanceof TimestampWritable) {
            Timestamp t = ((TimestampWritable)entry.getValue()).getTimestamp();
            doc.setField(key, dateFormat.format( new Date(t.getTime()) ));
        } else if (entry.getValue() instanceof ShortWritable) {
            doc.setField(key, ((ShortWritable)entry.getValue()).get());
        } else {
            doc.setField(key, entry.getValue().toString());
        }

    }
    log.debug("doc:"+doc.toString());
    table.save(doc);
}