社区版的license 对核数做了限制,限制为2核。 这种情况下配置更大的workerNum 也不起作用,反而多个任务可能会相互竞争资源,性能还可能会有下降。
回答于 2023-01-10 16:03
这里的X=x_series 必须是向量,而实际类型却是matrix。 由于y_matrix 是indexedMatrix,所以不需要tmbeta的T提供索引,可以改用mbeta mbeta(X=x_series,Y=y_matrix,window=10) 用tmbeta,可以改为 y1_matrix=matrix(table(Y1 as y1, Y2 as y2))tmbeta(T,X=x_series[0],Y=y1_matrix[0],window=10)
回答于 2022-09-30 20:02
二者的内部实现都是构造了Table类对象,区别只在于不同的参数; 单从传入tableName而言,两者区别在于loadTable没开GC(GC是Table 类的自动回收机制),table函数开了GC; 如果从函数使用限制来讲,table还可以本地上传df。
回答于 2022-09-30 19:53
server 端通过 GUI 创建一个跨进程内存表,并向该表实时写入数据//创建流表 share streamTable(10000:0,`timestamp`temperature, [TIMESTAMP,DOUBLE]) as pubTable; //创建跨进程共享内存表 share createIPCInMemoryTable(1000000, "pubTable", `timestamp`temperature, [TIMESTAMP, DOUBLE]) as shm_test; //自定义订阅处...
回答于 2022-09-19 09:16
使用TSDB 引擎,必须指定sortColumns参数。TSDB引擎根据sortColumns 的各列的顺序维护一个索引,因此可以优先把查询频率高的字段作为sortColumns 中位置靠前的列。例如: dbName = "dfs://tsdb_value_int" if(existsDatabase(dbName)){ dropDatabase(dbName) } db = database(directory=dbName, partitionType=VALUE, part...
回答于 2022-09-19 09:12
流数据表是在内存中的,当重启server 后,内存中的数据会丢失,为了防止流表数据丢失和流表占用内存过大,通常使用enableTableShareAndPersistence 和enableTablePersistence 函数。 enableTableShareAndPersistence 函数是把流数据表共享,并持久化到硬盘上。 enableTablePersistence 函数是把共享的流数据表持久化到硬...
回答于 2022-09-09 11:21
在GUI菜单栏依次选择Run -> Export table,而后按需填写Save Path 和sql 语句 例如: Save Path D:/test.csv 1.如果是读取分布式表,sql语句为 select * from loadTable("dfs://test",`pt) 2.如果是内存表,需要先将内存表共享,再导出数据并填写sql语句 先在GUI的编辑器执行 share t as st 再通过上述...
回答于 2022-09-05 14:59