0

我在 NiFi 中建立了一个管道,我在其中获取 JSON 记录,然后我使用这些记录向 API 发出请求。我得到的响应将包含数字和文本数据。然后我必须将此数据写入 Hive。我InferAvroSchema用来推断模式。一些数值是带符号的值,例如-2.46,-0.1在推断类型时,处理器将它们视为string而不是doublefloatdecimal类型。

我知道我们可以在处理器中对我们的 AVRO 模式进行硬编码,但我认为利用 AVRO 模式使其更具动态性InferAvroSchema会更好。还有其他方法可以克服/解决这个问题吗?

4

1 回答 1

3

InferAvroSchema 非常适合猜测初始模式,但是一旦您需要更具体的内容,最好删除 InferAvroSchema 并提供您需要的确切模式。

于 2017-02-28T15:00:54.110 回答