我想向我的输出适配器发送一个有效负载窗口。我需要所有这些都同时进入我的输出适配器,而不是一个一个。
所以,到目前为止我有:
var filteredCepStream = (from window in cepStream.HoppingWindow(
TimeSpan.FromMinutes(outputConfig.WindowLength),
TimeSpan.FromMinutes(outputConfig.WindowHopSize),
HoppingWindowOutputPolicy.ClipToWindowEnd)
select window);
但 StreamInsight 不允许我通过窗口发送。有什么方法可以使用户定义的聚合或其他东西将其转换为有效负载列表以发送到输出适配器?我要这样做是错误的方式吗?我真的需要将窗口中的所有有效负载同时发送到输出适配器。
谢谢!!
迪娜