in flume-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java [108:128]
private Map<String, String> getHeaders(HttpServletRequest request) {
if (LOGGER.isDebugEnabled() && LogPrivacyUtil.allowLogRawData()) {
Map requestHeaders = new HashMap();
Enumeration iter = request.getHeaderNames();
while (iter.hasMoreElements()) {
String name = (String) iter.nextElement();
requestHeaders.put(name, request.getHeader(name));
}
LOGGER.debug("requestHeaders: {}", requestHeaders);
}
Map<String, String> headers = new HashMap();
if (request.getContentType() != null) {
headers.put(Metadata.CONTENT_TYPE, request.getContentType());
}
Enumeration iter = request.getParameterNames();
while (iter.hasMoreElements()) {
String name = (String) iter.nextElement();
headers.put(name, request.getParameter(name));
}
return headers;
}