in crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java [198:220]
private void logRequest(SolrRequest request) {
if(request instanceof UpdateRequest) {
final StringBuilder rmsg = new StringBuilder(64);
String collection = request.getCollection();
rmsg.append("Submitting update request for collection=").append(collection != null ? collection : request.getParams().get("collection"));
if(((UpdateRequest) request).getDeleteById() != null) {
final int numDeleteByIds = ((UpdateRequest) request).getDeleteById().size();
metrics.counter("numDeleteByIds").inc(numDeleteByIds);
rmsg.append(" numDeleteByIds=").append(numDeleteByIds);
}
if(((UpdateRequest) request).getDocuments() != null) {
final int numUpdates = ((UpdateRequest) request).getDocuments().size();
metrics.counter("numUpdates").inc(numUpdates);
rmsg.append(" numUpdates=").append(numUpdates);
}
if(((UpdateRequest) request).getDeleteQuery() != null) {
final int numDeleteByQuery = ((UpdateRequest) request).getDeleteQuery().size();
metrics.counter("numDeleteByQuery").inc(numDeleteByQuery);
rmsg.append(" numDeleteByQuery=").append(numDeleteByQuery);
}
log.info(rmsg.toString());
}
}