if self.config.deduplicate_order_by_type == "asc": order_by_columns = [F.col(column_name) for column_name in self.config.deduplication_order_columns] ranking_column = "duplicates_rank" is_deleted_column = "IsDeleted"
时间: 2024-04-05 12:35:42 浏览: 56
Like-and-OrderBy.rar_sql like order by
这段代码主要是对选择的排序方式进行判断,并且选择相应的列名。如果 `self.config.deduplicate_order_by_type` 的值是 "asc",则表示需要按照升序排序,此时 `order_by_columns` 列表中存储的是需要排序的列名对应的 F.col() 函数;如果 `self.config.deduplicate_order_by_type` 的值是 "desc",则表示需要按照降序排序,此时需要将 `order_by_columns` 列表中的每个元素调用 F.col().desc() 方法,表示按照降序排序;`ranking_column` 和 `is_deleted_column` 分别是用于存储生成的新列名和标记是否删除的列名。
阅读全文