Как использовать несколько TimeSeriesAggregator одновременно в DolphinDB？ - PullRequest
Новая
       17

Как использовать несколько TimeSeriesAggregator одновременно в DolphinDB？

0 голосов
/ 30 апреля 2019

TimeSeriesAggregators не может работать одновременно.

Я использовал submitJob, чтобы убедиться, что каждый TimeSeriesAggregator работает в отдельном потоке, и использовал getRecentJobs для определения затрат времени.

Кажется странным, что каждая продолжительность трех параллельных заданий примерно в 2,5 раза больше, чем при выполнении независимого задания.

Все использованные мной TimeSeriesAggregator не предоставили ни одной таблицы или данных.

Часть моего сценария: 

aggr1 = createTimeSeriesAggregator(`aggr1, 60000, 1000, <sum(value)>, input1, result1, `timestamp,,`id)
aggr2 = createTimeSeriesAggregator(`aggr2, 60000, 1000, <sum(value)>, input2, result2, `timestamp,,`id)
aggr3 = createTimeSeriesAggregator(`aggr3, 60000, 1000, <sum(value)>, input3, result3, `timestamp,,`id)

submitJob("insert", "insert into aggr1", append!, aggr1, data)
submitJob("insert", "insert into aggr2", append!, aggr2, data)
submitJob("insert", "insert into aggr2", append!, aggr3, data)

Как запустить TimeSeriesAggregator одновременно с разумными затратами времени?

...