タイムスタンプ別にHbaseプロセッサのフィルタ行を取得する

Question

HBaseをNIFIで取得しようとしていますが、hbaseプロセッサでこのコマンドを実行したいのですが可能ですか？

scan 't1', {COLUMNS => 'c1', TIMERANGE => [1303668804, 1303668904]} 

Answer 1

GetHBaseプロセッサは、タイムスタンプに基づいて、HBaseのテーブルから増分抽出を行うようになっています。初期時間範囲プロパティは、プロセッサが前の実行で見られた最大時間を追跡しており、それを次回の実行で最小時間として使用した後、最小時間が0または現在の時刻で開始するかどうかを決定します。したがって、あなたが自分のtimerangeを提供することはできません。プロセッサがそれを管理しているからです。

Answer 2

GetHBaseプロセッサは、常にタイムスタンプに基づいて増分更新を探します。基本的には、新しい/更新されたデータを自動的に認識します。

しかし、あなたはまだタイムスタンプ（S）のために特別に行を読みたい場合は、タブ「フィルタ式」で、次の形式で正規表現を使用する必要があります。

TimeStampsFilter（timestamp1、timestamp2 ....タイムスタンプ）

これらのフィルタのリストは、https://www.cloudera.com/documentation/enterprise/5-3-x/topics/admin_hbase_filtering.html

にあります。