From 3702f5842a34c733198f6cfbf803cf1f7e4863cb Mon Sep 17 00:00:00 2001
From: Aldo Gonzalez <aldo.gonzalez@airbyte.io>
Date: Tue, 12 Nov 2024 14:27:21 -0600
Subject: [PATCH] Airbyte-protocol: add new record message type

---
 .../airbyte_protocol/airbyte_protocol.yaml    | 25 +++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/protocol-models/src/main/resources/airbyte_protocol/airbyte_protocol.yaml b/protocol-models/src/main/resources/airbyte_protocol/airbyte_protocol.yaml
index 3a5d634..ab1000d 100644
--- a/protocol-models/src/main/resources/airbyte_protocol/airbyte_protocol.yaml
+++ b/protocol-models/src/main/resources/airbyte_protocol/airbyte_protocol.yaml
@@ -122,6 +122,31 @@ definitions:
           - SOURCE_RETRIEVAL_ERROR
           # Errors casting to appropriate type
           - DESTINATION_TYPECAST_ERROR
+  AirbyteFileTransferRecordMessage:
+    type: object
+    additionalProperties: true
+    required:
+      - stream
+      - file
+      - emitted_at
+    properties:
+      namespace:
+        description: "namespace the data is associated with"
+        type: string
+      stream:
+        description: "stream the data is associated with"
+        type: string
+      file:
+        description: "transfer file data"
+        type: object
+        existingJavaType: com.fasterxml.jackson.databind.JsonNode
+      data:
+        description: "record data"
+        type: object
+        existingJavaType: com.fasterxml.jackson.databind.JsonNode
+      emitted_at:
+        description: "when the data was emitted from the source. epoch in millisecond."
+        type: integer
   AirbyteStateMessage:
     type: object
     additionalProperties: true