1

DolphinDBのストリームアグリゲーターでユーザー定義関数を使いたいです。

ただし、例外が返され、対処方法がわかりません。

def mymid(vec){
    return (first(vec) + last(vec))/2
}
share streamTable(10000:0, `time`device`metric, [TIMESTAMP, SYMBOL, DOUBLE] as sensor
output = table(10000:0, `time`mymid, [TIMESTAMP, DOUBLE]);
aggregator = createStreamAggregator("aggregator", 120, 60, <mymid(metric)>, sensor, output, `time)


execution was completed with exception
Usage: createStreamAggregator(name, windowSize, step, metrics, dummyTable, outputTable, timeColumn, [useSystemTime=false], [keyColumn], [garbageSize]). 
the outermost meta code must be aggregated functions.

明らかにmymid集約関数です。私の質問は、DolphinDB で集約されたユーザー定義関数を作成する方法です。

4

1 に答える 1