WSO2 DAS-Сколько DAS может хранить данные в памяти, используя Siddhi?

Question

Я новичок в 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 может не загружать много данных. Я думаю, что это должно загрузить много данных. У моего сервера достаточно памяти.

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

Answer 1

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

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

-Xms2048m -Xmx2048m -XX:MaxPermSize=1024m