def METHOD_NAME(
    self,
    node: TraversalNode,
    policy: Policy,
    privacy_request: PrivacyRequest,
    rows: List[Row],
    input_data: Dict[str, List[Any]],
) -> int:
    """Execute a masking requestfor DynamoDB"""
    query_config = self.query_config(node)
    collection_name = node.address.collection
    update_ct = 0
    for row in rows:
        update_items = query_config.generate_update_stmt(
            row, policy, privacy_request
        )
        if update_items is not None:
            client = self.client()
            update_result = client.put_item(
                TableName=collection_name,
                Item=update_items,
            )
            if update_result["ResponseMetadata"]["HTTPStatusCode"] == 200:
                update_ct += 1
            logger.info(
                "client.put_item({}, {})",
                collection_name,
                Pii(update_items),
            )
    return update_ct