FixedWindowsとDurationでのValueProvider <Long>の使用

Question

Apache Beam 2.xに移行するには、可能な限りテンプレートを使用し、それに応じてValueProviderを使用したいと考えています。

私のロジックでは、FixedWindowを使用していますが、期間は柔軟なので、むしろValueProviderから取得します。

FixedWindows.of（）はDurationしか取得できないため、ValueProviderを取得してそこから期間を取る簡単な方法を見つけることができませんでした。これは現在サポートされていません。

教えてください、 シュシュ

Answer 1

残念ながら、この質問には簡単な答えを持っています。 file a JIRAに気軽に - それは合理的な要求のようです。

Answer 2

今日SlidingWindowsでは、SlidingWindowsを使用して、代わりにValueProvider（https://github.com/apache/beam/pull/3358/filesに似ています）という新しいパラメータを持つ独自のウィンドウ関数を書きましたが、これはうまくいくようです。