从 kafka spout 获取模式的 Storm- Routing bolt

Question

当我尝试使用 declareOutputFields() 输出数据时，如何获取 Split Bolt 中的数据模式。

字段架构 = 新字段(?)

如何在不基本上重新解析所有数据并重新创建数据的情况下获取此螺栓内数据中所有字段的模式？

Answer 1

您需要事先了解架构，即在处理第一个元组之前。在首次调用 execute().

之前，在部署期间调用方法 declareOutputFields()

Storm 无法处理变量模式。如果您有 JSON 结构未知的数据，您可以声明 new Fields("json") 并将整个 JSON 对象放入一个字段中。