オブジェクトの順序付けられた一連のストリーム/イテレータ用に解決された DSL があるかどうか疑問に思います (そしてほとんど絶望的になります)。
ソースは、id、time、key、value インスタンスの順序付けられたストリームであり、要件はこれらのストリームに参加して分析することです。これは、キーの組み合わせを収集し、特定の (定義可能な) 時間制約内の値にメトリックを適用することによって実行する必要があります (1 日内、同じ秒内で個別のキーまたは合計値をカウントする..)。時系列（ESP）で動作するいくつかのDSLがありますが、ほとんどは比較的単純な時間枠を使用しており、ID、時間などによる順序/結合を処理できないようです（結果として、IDによる組み合わせの計算）。
私がしなければならないことは、「Aと（BまたはC）の組み合わせを計算し、同じ秒内に異なるDを数え、同じIDでEを合計する」のようなものです
結果には、A、(B または C) のすべての使用可能な組み合わせと、キー D の個別の値の数が含まれている必要があります。これらは、個別の ID ごとに A、(B または C) と同じ秒にあり、キーの値の合計です。各 ID の E (これは、A、(B または C) を持つ ID の E のすべての値の合計です)。
簡単な質問ではありません。私はちょうど役立つかもしれない、すでにそのような問題のための DSL を考えています。私はSQLがうまくいくとは思わない。
どうもありがとう！