我正在嘗試創建一些單元測試以驗證我的Trident拓撲的某些部分正在做他們應該做的事情。 我想能夠檢索運行拓撲後產生的所有值,並把它們放在一個列表,所以我可以「看」他們並檢查他們的條件。 FeederBatchSpout feederSpout = new FeederBatchSpout("some_time_field", "foo_id");
TridentTopology top
例如 topology.newStream("process", new RawDataSpout())
.parallelismHint(1)
.shuffle()
.each(new Fields("frameID"), new RawToRgb(), new Fields("frameIDRawToRgbCompleted"))