如何按特定参数值统计代理数量并通过柱状图可视化展示

你之前使用的sink.count(agent.product_type = "A400S")写法不生效，是因为统计函数的过滤规则不能直接以键值对形式传入count参数，需要先调用filter方法完成数据筛选后再执行计数。

正确配置步骤如下：

• 首先过滤出所有代理名称为Sitz的数据集，排除其他无关代理的统计干扰
• 针对需要统计的两个product_type取值，分别追加类型过滤条件后执行count计数，对应柱状图的两个柱条取值

可直接复用的配置代码：

# 对应柱条：Sitz product_type = A400S
sink.filter(agent.name == "Sitz" && agent.product_type == "A400S").count()

# 对应柱条：Sitz product_type = A660
sink.filter(agent.name == "Sitz" && agent.product_type == "A660").count()

如果你使用的可视化工具支持分组聚合能力，更推荐直接对过滤后的Sitz代理数据集按product_type字段做分组计数，工具会自动生成对应分类的柱条，后续新增产品类型时不需要手动修改统计配置。

内容的提问来源于stack exchange，提问作者SimulationNewBe