如何在Spark DataFrame中实现SQL的双变量计数与去重计数逻辑

下面是各类内容对应的Markdown格式写法：

• 标题：用井号（#）标识，井号数量对应标题层级（1-6级）
  示例：

  # 一级标题
  ## 二级标题
  ### 三级标题
  

• 列表项：以短横线（-）开头，支持嵌套
  示例：

  - 普通列表项
  - 另一个列表项
    - 嵌套列表项1
    - 嵌套列表项2
  

• 强调文本：用星号（*）包裹，单星号为斜体，双星号为粗体
  示例：

  *斜体强调内容*
  **粗体强调内容**
  

• 代码/命令：单行用单个反引号（`）包裹，多行用三个反引号包裹并可指定语言
  单行示例：

  `git status`
  

  多行示例：

  public class Main {
      public static void main(String[] args) {
          System.out.println("Hello");
      }
  }
  

• 引用文本：用大于号（>）开头
  示例：

  > 这是一段引用内容
  > 换行后继续引用会自动衔接
  

• 链接：显示文本放方括号（[]），目标URL放括号（()）
  示例：

  [开源项目地址](https://github.com/example)
  

• 图片：替代文本放方括号（[]），图片URL放括号（()）
  示例：

  [风景图片](https://example.com/scenery.jpg)
  

内容的提问来源于stack exchange，提问作者Kenzo-San