Tracking Update

gistfile1.txt

public class TrackingUpdateRequestProcessor extends UpdateRequestProcessor {
    private final SchemaField sf;
    public static ConcurrentHashMap<BytesRef, Long> changes = new ConcurrentHashMap<>();

    public TrackingUpdateRequestProcessor(SolrQueryRequest req, UpdateRequestProcessor next) {
        super(next);
        sf = req.getCore().getLatestSchema().getUniqueKeyField();
    }

    @Override
    public void processAdd(AddUpdateCommand cmd) throws IOException {
        BytesRefBuilder b = new BytesRefBuilder();
        sf.getType().readableToIndexed(cmd.getSolrInputDocument().getFieldValue("id").toString(), b);
        changes.put(b.get(), 1L);
        super.processAdd(cmd);
    }

    @Override
    public void processDelete(DeleteUpdateCommand cmd) throws IOException {
        changes.put(cmd.getIndexedId(), 0L);
        super.processDelete(cmd);
    }
}