我是大数据的新手。我有些怀疑。如果我能弄明白，那将非常有帮助。我需要对窗口流进行聚合。我有一个 kafka 主题，其中包含嵌套 json 中的数据。我需要在ktable中转换json并聚合6小时、12小时和24小时。我有一些疑问
- 如何展平多嵌套的 json。我需要采用表格格式
- 如何以 k,v 格式的 kafka 从 v 访问每个元素。
- 如何将 v 中的一列作为新键。
- 我应该如何聚合。每 6 小时、12 小时和 24 小时的 Ktable，或者我应该有 1 个 ktable 并且可以在查询时聚合。