in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java [267:279]
public Builder setHeader(long headerId, String baseName, String baseValue) {
if (bHeaderParts == null) {
bHeaderParts = new HashMap<Long, HeaderPart>();
}
HeaderPart hp = new HeaderPart(baseName, baseValue);
if (bHeaderParts.put(headerId, hp) != null) {
throw new JdbcChannelException("Duplicate header found: "
+ "headerId: " + headerId + ", baseName: " + baseName + ", "
+ "baseValue: " + baseValue);
}
return this;
}