エンドユーザー API がオブジェクト/イベントのリストで集計を受け取る機能エンジニアリング用のシステムを Scala で構築しています。たとえば、このツールのクライアントは、特定の Web ユーザーの過去のページビューの配列を指定して、特定の国からのページ ビューをフィルター処理してカウントする関数をツールに渡すことができます。この呼び出しの出力は数値になります。
これは非常に単純な縮小操作と考えることができます。そのようなシステムの API を構築する方法を考えています。カウントとフィルターを実行する単純なカスタム言語を作成することもできますが、注意して設計しない限り、特に十分な表現力が得られないため、最善の方法ではないことは確かです。
私が最初から作成しなくても、単純な関数を表現するために使用できる式言語のようなものを知っていますか? もう 1 つのオプションは、エンド ユーザーがカスタム コードをこのライブラリに渡すことを許可することですが、これは実行時に危険な場合があります。
SQLをさまざまなデータ構造とデータベースにプラグインするapache Calciteを認識しています。これは良いオプションですが、「列」SQL の方法で考える必要がありますが、ここでは、プログラミングの map-reduce 方法に似た行ベースの何かを探しています。