3

我正在尝试在 Druid 本机查询中执行 groupby 虚拟列，如下所示...

{
  "queryType": "groupBy",
  "dataSource": "trace_info",
  "granularity": "none",
  "virtualColumns": [
    {
      "type": "expression",
      "name": "tenant",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'tenant')), 'tenant:', '')"
    },
    {
      "type": "expression",
      "name": "rc",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'row_count')), 'row_count:', '')"
    }
  ],
  "dimensions": [
    "tenant"
  ],
  "aggregations": [
    {
      "type": "longSum",
      "name": "trc",
      "fieldName": "rc"
    }
  ],

...
...
...

  "intervals": [
    "..."
  ]
}

这给出了所有 row_counts 的 longsum 的单行，就好像 groupBy 列为空一样。

我的用法是正确的还是德鲁伊中的一个已知问题。文档说虚拟列可以像普通尺寸一样使用，但是对于如何甚至缺少工作示例并不是很清楚。

谢谢！帕尼

4

1 回答 1

0

最新编辑...

进一步挖掘发现问题在于虚拟列上缺少“outputType”属性。奇怪，因为聚合器能够自动检测时间并正确计算长和，即使按结果分组是错误的。

  "virtualColumns": [
    {
      "type": "expression",
      "name": "tenant",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'tenant')), 'tenant:', '')",
      "outputType": "STRING"
    },
    {
      "type": "expression",
      "name": "rc",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'row_count')), 'row_count:', '')"
      "outputType": "LONG"
    }
  ],

见上文（下文可能是解决问题的一种非高效方式）。

经过一些试验和错误，我有一个使用提取尺寸的解决方法。虽然不确定，但我怀疑这是 Druid 0.18.1 中的临时问题。希望对 VC 进行分组将在未来的构建中像宣传的那样工作。

{
  "queryType": "groupBy",
  "dataSource": "trace_info",
  "granularity": "none",
  "virtualColumns": [
    {
      "type": "expression",
      "name": "tenant",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'tenant')), 'tenant:', '')"
    },
    {
      "type": "expression",
      "name": "rc",
      "expression": "replace(array_offset(tags, array_offset_of(tagNames, 'row_count')), 'row_count:', '')"
    }
  ],
  "dimensions": [
    {
      "type": "extraction",
      "dimension": "tenant",
      "outputName": "t",
      "extractionFn": {
        "type" : "substring", "index" : 1
      }
    }
  ],
  "aggregations": [
    {
      "type": "longSum",
      "name": "trc",
      "fieldName": "rc"
    }
  ],

...
...
...

  "intervals": [
    "..."
  ]
}
于 2020-08-07T05:04:34.107 回答