static ElasticsearchDestinationConfiguration translateElasticsearchDestinationConfigurationToCfnModel()

in deliverystream/src/main/java/com/amazonaws/kinesisfirehose/deliverystream/HandlerUtils.java [938:960]

23 lines of code
4 McCabe index (conditional complexity)


	static ElasticsearchDestinationConfiguration translateElasticsearchDestinationConfigurationToCfnModel(
			final ElasticsearchDestinationDescription elasticsearchDestinationDescription) {
		return elasticsearchDestinationDescription == null ? null : ElasticsearchDestinationConfiguration.builder()
				.bufferingHints(elasticsearchDestinationDescription.bufferingHints() == null ? null : ElasticsearchBufferingHints.builder()
						.intervalInSeconds(elasticsearchDestinationDescription.bufferingHints().intervalInSeconds())
						.sizeInMBs(elasticsearchDestinationDescription.bufferingHints().sizeInMBs())
						.build())
				.cloudWatchLoggingOptions(translateCloudWatchLoggingOptionsToCfnModel(elasticsearchDestinationDescription.cloudWatchLoggingOptions()))
				.clusterEndpoint(elasticsearchDestinationDescription.clusterEndpoint())
				.domainARN(elasticsearchDestinationDescription.domainARN())
				.indexName(elasticsearchDestinationDescription.indexName())
				.indexRotationPeriod(elasticsearchDestinationDescription.indexRotationPeriodAsString())
				.processingConfiguration(translateProcessingConfigurationToCfnModel(elasticsearchDestinationDescription.processingConfiguration()))
				.retryOptions(elasticsearchDestinationDescription.retryOptions() == null ? null : ElasticsearchRetryOptions.builder()
						.durationInSeconds(elasticsearchDestinationDescription.retryOptions().durationInSeconds())
						.build())
				.roleARN(elasticsearchDestinationDescription.roleARN())
				.s3BackupMode(elasticsearchDestinationDescription.s3BackupModeAsString())
				.s3Configuration(translateS3DestinationConfigurationToCfnModel(elasticsearchDestinationDescription.s3DestinationDescription()))
				.typeName(elasticsearchDestinationDescription.typeName())
				.vpcConfiguration(translateVpcConfigurationToCfnModel(elasticsearchDestinationDescription.vpcConfigurationDescription()))
				.build();
	}