Apache Stormでシミュレーション時間を使ってJava単体テストを書く方法は？

Question

私は毎分の集計を計算するStormトポロジを持っています。 私はJavaユニットテストでアプリケーションをカバーしたいと思いますが、私は Javaユニットテストの実例を見つけることができません。

時間の変化をシミュレートし、トポロジの出力を取得してテストする必要があります。

Answer 1

解決策はあるように思わ：

一緒 Timeクラスとその有用手動タイム前進方法で（どういうわけかすべてのJavadocから欠落） Testingクラスを利用

Testing.withSimulatedTimeLocalCluster(new TestJob() { 
    public void run(Cluster cluster) { 
     // your testing logic here. 
     Time.advanceTime(100); 
    } 
}); 

。

これは、ウィンドウのスライディングなどのために使用されるStormの内部時計に役立つことに注意してください。あなた自身のコードでは、シミュレーションされた時間も認識する必要があります。 Javaの世界でこれを行うための標準的な方法として、Clockクラス（Java 8のみ）、または012oda6-timeを使用している場合はDateTimeUtilsクラスがあります。