From ddb950d760a846b3c59936bd7f77d08fb3828998 Mon Sep 17 00:00:00 2001 From: Jean-Baptiste Le Duigou Date: Tue, 12 Nov 2024 09:17:29 +0000 Subject: [PATCH] feat: support of otf metadata for iceberg destinations --- events/firehose.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/events/firehose.go b/events/firehose.go index 85b8fd18..f01da504 100644 --- a/events/firehose.go +++ b/events/firehose.go @@ -37,7 +37,14 @@ type KinesisFirehoseResponseRecord struct { } type KinesisFirehoseResponseRecordMetadata struct { - PartitionKeys map[string]string `json:"partitionKeys"` + PartitionKeys map[string]string `json:"partitionKeys"` + OtfMetadata KinesisFirehoseResponseRecordMetadataOtfMetadata `json:"otfMetadata"` +} + +type KinesisFirehoseResponseRecordMetadataOtfMetadata struct { + DestinationDatabaseName string `json:"destinationDatabaseName"` + DestinationTableName string `json:"destinationTableName"` + Operation string `json:"operation"` } type KinesisFirehoseRecordMetadata struct {