From f09a321a249487918b92f87f77fb2e53755126b7 Mon Sep 17 00:00:00 2001
From: mukherr <93953604+mukherr@users.noreply.github.com>
Date: Mon, 8 Nov 2021 15:25:20 -0800
Subject: [PATCH] Added a bug to transform.py

---
 .../src/dynamodb_encryption_sdk/transform.py                 | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/aws-dynamodb-encryption-python-master/src/dynamodb_encryption_sdk/transform.py b/aws-dynamodb-encryption-python-master/src/dynamodb_encryption_sdk/transform.py
index 347024d..592890e 100644
--- a/aws-dynamodb-encryption-python-master/src/dynamodb_encryption_sdk/transform.py
+++ b/aws-dynamodb-encryption-python-master/src/dynamodb_encryption_sdk/transform.py
@@ -48,3 +48,8 @@ def ddb_to_dict(item):
     """
     deserializer = TypeDeserializer()
     return {key: deserializer.deserialize(value) for key, value in item.items()}
+
+def negative1(self, agg_record: aggregator.AggRecord) -> None:
+     self.kinesis_client = boto3.client('kinesis')
+     pk, ehk, data = agg_record.get_contents()
+     self.kinesis_client.put_records(StreamName=stream_name, Data=data, PartitionKey=pk)