我必须使用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的。
暂无答案!
目前还没有任何答案,快来回答吧!