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)