оператор share не может быть объявлен в определении функции в DolphinDB - PullRequest
1 голос
/ 06 июня 2019

Я пытаюсь обработать поток функции 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)

1 Ответ

0 голосов
/ 07 июня 2019

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

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