WSO2 DAS — Сколько данных DAS может хранить в памяти с помощью Siddhi?

Я новичок в WSO2 DAS. Согласно документу, в нем говорится, что DAS может быстро анализировать данные. Я пытаюсь сделать пример. Мой сценарий, как показано ниже.


@Import('in_test_stream:1.0.0')
define stream inStream (a string, b string);    *---> receive data*

@Export('out_other_stream:1.0.0')
define stream outOtherStream (a int);

@Export('out_test_stream:1.0.0')
define stream outStream (a string, b string, c string);

define table tmpTable (a long, b long, reg_date string);--> define meomry table for faster analytics

@info(name='query1')   *---> loading incoming data into memory table.*
from inStream
select convert(a, 'long') as a, convert(b, 'long') as b, time:currentTimestamp() as reg_date
insert into tmpTable;

@info(name='query2')  *--> maintain some number of data....the others will be delete....*
from inStream
delete tmpTable
    on time:timestampInMilliseconds(tmpTable.reg_date, 'yyyy-MM-dd HH:mm:ss') < time:timestampInMilliseconds(time:dateSub(time:currentTimestamp(), 1, 'day', 'yyyy-MM-dd HH:mm:ss'), 'yyyy-MM-dd HH:mm:ss');

@info(name='query3')--> This is kind of analyzing data and push it to output...
from inStream as k1 join tmpTable as k2
select convert(stddev(k2.a), 'string') as a, convert(count(k2.b), 'string') as b, k2.reg_date as c
insert into outStream;

Я делаю план объяснения, как описано выше. Проблема в том, что tmpTable может не загружать много данных. Я думаю, что он должен загрузить много данных. На моем сервере достаточно памяти.

Помогите мне, пожалуйста.


person youngwoo    schedule 11.09.2016    source источник


Ответы (1)


У вашего сервера может быть много памяти, но вам следует выделить больше памяти на уровне JVM для экземпляра DAS, поскольку он использует выделение памяти по умолчанию. Вы можете настроить параметры JVM в файле /bin/wso2server.bat в Windows или файле /bin/wso2server.sh в Linux, открыв его в текстовом редакторе.

Затем увеличьте следующие параметры

-Xms2048m -Xmx2048m -XX:MaxPermSize=1024m
person Tharik Kanaka    schedule 13.09.2016