оператор share не может быть объявлен в определении функции в DolphinDB

Я пробую функцию потоковой обработки dolphindb. И я хочу, чтобы другой узел подписался на текущий узел, поэтому я написал следующий код. Но графический интерфейс dolphindb каким-то образом сообщает Syntax Error: [line #2] share statement can't be declared within a function definition. Означает ли это, что мне нужно открыть еще один сеанс, затем подключиться к NODE2 и подписаться вручную?

def mySub(PUBNODE, src) {
    share streamTable(1:0, [`c1], [INT]) as t
    subscribeTable(server=PUBNODE, tableName = src, handler = objByName(`t))
}

share streamTable(1:0, [`c1], [INT]) as `src
rpc(NODE2, mySub, getNodeAlias(), `src)

database stream-processing dolphindb
person Ju Piece    schedule 06.06.2019    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Пожалуйста, используйте функцию общего доступа, чтобы поделиться таблицей потоковой передачи между сеансами.

def mySub(PUBNODE, src) {
    share(streamTable(1:0, [`c1], [INT]), "t")
    subscribeTable(server=PUBNODE, tableName = src, handler = objByName(`t))
}
person Davis Zhou    schedule 07.06.2019