Flink でオペレーター間で状態を共有することは可能でしょうか。
たとえば、オペレーターでキーによるパーティション分割があり、(何らかの理由で) パーティションA内のパーティションの状態が必要であるとCします (図 1.a)、またはC下流のオペレーターでオペレーターの状態が必要であるF(図 1 . .b)。
broadcastすべてのパーティションに記録できることはわかっています。したがって、オペレーターの内部状態をレコード内に含めると、内部状態を下流のオペレーターと共有できます。
ただし、これは単に状態をop1具体的に要求するのではなく、コストのかかる操作になる可能性がありop2ます。
クエリ可能な状態に関する最近の開発は、この概念に向かって進んでいますか?それとも、外部ユーザーがトポロジの内部状態をクエリできるようにするためだけのものですか?
あなたの洞察を前もってありがとう