1

我可以在 UDSO 中做到这一点：

public sealed class PromoIdsToEvents : CepPointStreamOperator<string, int>
{
    public override IEnumerable<int> ProcessEvent(PointEvent<string> inputEvent)
    {
        if (inputEvent.Payload.Length > 0)
        {
            string[] separator = new[] { "," };
            string[] idStrings = inputEvent.Payload.Split(separator, StringSplitOptions.RemoveEmptyEntries);

            foreach (var p in idStrings)
            {
                yield return int.Parse(p);
            }
        }
    }

    public override bool IsEmpty
    {
        get { return false; }
    }
}

是否可以在查询中完成所有操作？所有这一切都是使 IEnumberable ：

var multipleEventsAsInts = from c in csvEvents
                           let split = c.Split(',').Select(int.Parse)
                           select split;
4

2 回答 2

1

您可能能够在某个主题中完成这项工作，但我认为您通过 UDSO 执行此操作的方式是以程序方式处理 StreamInsight 事件的正确方式。

通过创建该 UDSO，您现在拥有了可重用的代码块。如果您只是在查询逻辑中完成了这项工作，那么您将无法轻松地重用它。

于 2013-09-15T03:46:46.293 回答
0

TXPower 是绝对正确的。此外，UDSO 将比在查询中使用 UDF（静态方法）更有效。但是，您的示例 UDSO 可能会好一些……请注意，ProcessEvent 的返回值是一个 IEnumerable。您不需要一次只收益一个；创建您的可枚举（一个数组就可以了），然后简单地返回它。

于 2013-09-25T03:07:06.290 回答