in flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/TimeBasedIndexNameBuilder.java [75:87]
public void configure(Context context) {
String dateFormatString = context.getString(DATE_FORMAT);
String timeZoneString = context.getString(TIME_ZONE);
if (StringUtils.isBlank(dateFormatString)) {
dateFormatString = DEFAULT_DATE_FORMAT;
}
if (StringUtils.isBlank(timeZoneString)) {
timeZoneString = DEFAULT_TIME_ZONE;
}
fastDateFormat = FastDateFormat.getInstance(dateFormatString,
TimeZone.getTimeZone(timeZoneString));
indexPrefix = context.getString(ElasticSearchSinkConstants.INDEX_NAME);
}