in deliverystream/src/main/java/com/amazonaws/kinesisfirehose/deliverystream/HandlerUtils.java [833:850]
static ElasticsearchDestinationUpdate translateElasticsearchDestinationUpdate(final ElasticsearchDestinationConfiguration elasticsearchDestinationConfiguration) {
if (elasticsearchDestinationConfiguration == null) {
return null;
}
return ElasticsearchDestinationUpdate.builder()
.roleARN(elasticsearchDestinationConfiguration.getRoleARN())
.domainARN(elasticsearchDestinationConfiguration.getDomainARN())
.indexName(elasticsearchDestinationConfiguration.getIndexName())
.clusterEndpoint(elasticsearchDestinationConfiguration.getClusterEndpoint())
.indexRotationPeriod(elasticsearchDestinationConfiguration.getIndexRotationPeriod())
.bufferingHints(translateElasticsearchBufferingHints(elasticsearchDestinationConfiguration.getBufferingHints()))
.retryOptions(translateElasticsearchRetryOptions(elasticsearchDestinationConfiguration.getRetryOptions()))
.processingConfiguration(translateProcessingConfiguration(elasticsearchDestinationConfiguration.getProcessingConfiguration()))
.s3Update(translateS3DestinationUpdate(elasticsearchDestinationConfiguration.getS3Configuration()))
.cloudWatchLoggingOptions(translateCloudWatchLoggingOptions(elasticsearchDestinationConfiguration.getCloudWatchLoggingOptions()))
.typeName(elasticsearchDestinationConfiguration.getTypeName())
.build();
}