方法：マップなしでaerospike udfフィルターを作成するか、マップに完全なレコードを返します

Question

Aerospikeにフィルタとマップを含むudfストリームがあります。

私が見たすべての例によると、私はレコードからフィールドを選び、フィルタリングされ選択されたフィールドを持つ新しいマップを返すことができます。しかし、私はそれをしたくありません。私はどのようなストリームでも、どんなコラム/ビンでも、フィルタを適用してフルレコードを返すことを望みます。 1つのアプローチは、stream：fiter（my_filter）のようなものを使用し、マップを使用しないことです。直感的に（少なくとも私にとっては）これはストリームをフィルタリングして中継するだけです。これは、私の欲求不満に、動作しないようです。私が試した次のことは、マップを使用することですが、単純に完全なレコードを中継します。これはどちらもうまくいきません。両方のケースで、私はそれが私の結果として空リストを取得しないと言うとき。

これがどのように機能するのかを親切に説明できますか？それは私を絶対にナッツを運転している。 これは、世界で最も基本的なものの1つで、udfsと関係があります。私は、udfsでもっと複雑なことをたくさんやったことを指摘しなければならないが、何らかの理由でこれが私にとって問題である。

Answer 1

欠けていることは、UDFの戻り値でレコード型またはストリーム型を返すことができないことです。私は、すべての戻り値のタイプが、Aerospikeシステムのluaモジュールによってクライアント固有の型にマッピングされると信じています。レコード "タイプ"をマップすることはできません。

レコードを取得したい場合は、キーをビンに格納し、そのビンをマップタイプまたは文字列タイプまたは整数タイプ（アプリケーションに最も適したタイプ）に戻します。マップタイプのレコードメタデータからレコードダイジェストを返すこともできます。私はUDFを介してレコードダイジェストを取得して返しますが、試してみる価値はありません。

名前空間、キー、または名前空間&レコードダイジェストを設定したら、クライアントAPIからレコードにアクセスできます。レコードダイジェストは、セット名とキーの組み合わせから計算されたRIPEMD160ハッシュです。

Answer 2

私は何かが不足していると思う。 レコードudfsを使用してレコードを更新し、udfsをストリームしてクエリ/マップを減らしました。問題は、私がすべての列を選択できるようにがと思われるマップです。それらを検査せずに中継する。同等のSQLシステムと比較してください（この比較を行うことは必ずしも妥当とは限りません）。私は真のマップなしでudfsのフィルタ部分を使いたいです。どうして？セカンダリインデックスなしでセットを選択してフィルタリングする方法がないため、複数のフィルタが必要です。私はこれをどのようにして行うのですか？

Answer 3

エアロスパイクのレコードは、タプル（キー、メタデータ、ビン）です。 record UDFであるかstream UDFであるかにかかわらず、Aerospike UDF written in Luaは、サポートされている型（文字列、整数、倍精度、リスト、マップ、バイト）を返すことができます（Known Limitations参照）。ストリームUDFで

、あなただけがまだマップにレコードのビン名/ビン値のペアをキャストし、それを返すために必要なフィルタを持っている場合：

local function bins_match_filter(bin1, bin2) 
    return function(rec) 
    if rec[bin1] and rec[bin2] and 
     (type(rec[bin1]) == type(rec[bin2])) and 
     rec[bin1] == rec[bin2] then 
     return true 
    end 
    return false 
    end 
end 

local function record_to_map(rec) 
    local ret = map() 
    for i, bin_name in ipairs(record.bin_names(rec)) do 
    ret[bin_name] = rec[bin_name] 
    end 
    return ret 
end 

function check_bins_match(stream, bin1, bin2) 
    return stream : filter(bins_match_filter(bin1, bin2)) : map(record_to_map) 
end 

あなたがかもしれ特定のストリームUDFベースのフィルタをpredicate filter式に変換することができます。 2つのビンの値を比較する方法がないので、上記の例ではうまくいきません。しかし、ほとんどの場合、述語式の操作は適切です（JavaクライアントのクラスPredExpを参照してください）。 UDFをまったく呼び出す必要はありません。これははるかに速く、より優れたスケーラビリティを持ち、レコードをビン名と値のペアのマップにキャストする必要はありません。