2016-05-24 13 views
0

のHBaseはApache NIFIにアブロファイルを保存し、私は(convertAvroToJsonとputHbaseJSON)私は4属性のように取得していますOracleの私はORACLE DBからデータを取得しています

を使用せずにHBaseの中でそれを保存したい: A:テキスト B:テキスト C:テキスト D:バイナリ

があまりにも注意

アブロファイルから直接これらの属性を保存するどのような方法がある:JSONを使用して私を防ぐ唯一の理由は、BINARY属性でありますそれは含まれている可能性があります( "または")

ありがとうございます。

答えて

2

Apache NiFiが提供するすぐに使えるプロセッサでは、これを行う方法はないと思います。 PutHBaseAvroのような新しいプロセッサを実装する必要があります。これは、AvroからHBaseの突然変異に直接移行し、バイナリデータを適切に処理できます。

より簡単に新しいHBaseのプロセッサを置く実装するために拡張することができAbstractPutHBaseクラスがあります:

protected abstract PutFlowFile createPut(final ProcessSession session, final ProcessContext context, final FlowFile flowFile); 

:あなたは、次のメソッドを実装する必要があります

https://github.com/apache/nifi/blob/e4b7e47836edf47042973e604005058c28eed23b/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/main/java/org/apache/nifi/hbase/AbstractPutHBase.java

は、 FlowFileの内容をAvroとして読み込み、PutFlowFileに変換します。

これに取り組んで貢献したい場合は、HBaseプロセッサの素晴らしいエディションです。

関連する問題