私は NiFi でパイプラインを設定しています。ここで JSON レコードを取得し、それを使用して API にリクエストを送信します。私が受け取る応答には、数値データとテキスト データの両方が含まれます。次に、このデータを Hive に書き込む必要があります。私InferAvroSchemaはスキーマを推測するために使用します。一部の数値は次のような符号付きの値です。プロセッサは、型を推測している間、それらをor またはor型ではない-2.46,-0.1と見なします。stringdoublefloatdecimal
プロセッサで AVRO スキーマをハードコーディングできることはわかっていますが、 を利用してより動的にする方がさらに良いと思いInferAvroSchemaました。これを克服/解決できる他の方法はありますか?