in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java [305:324]
public PersistableEvent build() {
List<HeaderEntry> bHeaders = new ArrayList<HeaderEntry>();
if (bHeaderParts != null) {
for (long headerId : bHeaderParts.keySet()) {
HeaderPart part = bHeaderParts.get(headerId);
bHeaders.add(part.getEntry(headerId));
}
}
PersistableEvent pe = new PersistableEvent(bEventId, bChannelName,
bBasePayload, bSpillPayload, bHeaders);
bEventId = 0L;
bChannelName = null;
bBasePayload = null;
bSpillPayload = null;
bHeaderParts = null;
return pe;
}