in deliverystream/src/main/java/com/amazonaws/kinesisfirehose/deliverystream/HandlerUtils.java [1050:1082]
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();
}