in flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/SimpleIndexNameBuilder.java [34:36]
public String getIndexPrefix(Event event) { return BucketPath.escapeString(indexName, event.getHeaders()); }