如何使用avro格式的nifi querydatabasetable处理器接收oracle原始数据类型

ikfrs5lh  于 2021-06-24  发布在  Hive
关注(0)|答案(0)|浏览(284)

我必须使用nifi的querydatabasetable处理器从oracle中摄取一个原始数据类型中有一列的表。
原始列的示例数据集:

E2AE60ABCBB2570EEF9E41B813HHF18879C09E53
FC19E9D59124DB91C27848B8B401F0FB57276276
D2C07DFCB95DD0410EA139227962D2F973D66C51

但获取以下格式的数据

CREATE EXTERNAL TABLE IF NOT EXISTS dbname.tblname
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.avro.AvroSerDe'
STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerInputFormat'
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerOutputFormat'
LOCATION 'hdfs://location'
TBLPROPERTIES ('avro.schema.url'='hdfs://location/hash.avsc');

架构文件

{
"type":"record",              
"name":"summary_hash",
"fields":[
{"name":"ROW_FINGERPRINT_HASH","type":["null","bytes"]}
]}

我是新来nifi的。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题