static OutputFormatConfiguration translateOutputFormatConfigurationToCfnModel()

in deliverystream/src/main/java/com/amazonaws/kinesisfirehose/deliverystream/HandlerUtils.java [1050:1082]

33 lines of code
4 McCabe index (conditional complexity)


	static OutputFormatConfiguration translateOutputFormatConfigurationToCfnModel(
			software.amazon.awssdk.services.firehose.model.OutputFormatConfiguration outputFormatConfiguration) {
		if (outputFormatConfiguration == null) {
			return null;
		}
		val serializer = outputFormatConfiguration.serializer();
		return OutputFormatConfiguration.builder()
				.serializer(Serializer.builder()
						.parquetSerDe(serializer.parquetSerDe() == null ? null
								: ParquetSerDe.builder()
								        .blockSizeBytes(serializer.parquetSerDe().blockSizeBytes())
								        .compression(serializer.parquetSerDe().compressionAsString())
								        .enableDictionaryCompression(serializer.parquetSerDe().enableDictionaryCompression())
								        .maxPaddingBytes(serializer.parquetSerDe().maxPaddingBytes())
								        .pageSizeBytes(serializer.parquetSerDe().pageSizeBytes())
								        .writerVersion(serializer.parquetSerDe().writerVersionAsString())
								        .build())
						.orcSerDe(serializer.orcSerDe() == null ? null
								: OrcSerDe.builder()
								        .blockSizeBytes(serializer.orcSerDe().blockSizeBytes())
								        .bloomFilterColumns(serializer.orcSerDe().bloomFilterColumns())
								        .bloomFilterFalsePositiveProbability(serializer.orcSerDe().bloomFilterFalsePositiveProbability())
								        .compression(serializer.orcSerDe().compressionAsString())
								        .dictionaryKeyThreshold(serializer.orcSerDe().dictionaryKeyThreshold())
								        .enablePadding(serializer.orcSerDe().enablePadding())
								        .formatVersion(serializer.orcSerDe().formatVersionAsString())
								        .paddingTolerance(serializer.orcSerDe().paddingTolerance())
								        .rowIndexStride(serializer.orcSerDe().rowIndexStride())
								        .stripeSizeBytes(serializer.orcSerDe().stripeSizeBytes())
								        .build())
						.build())
				.build();
	}