cdh6.3安装hdfs报错
执行的命令 hdfs/hdfs.sh ["secondarynamenode"] Sun Jun 14 07:49:04 CST 2020JAVA_HOME=/usr/java/jdk1.8.0_181using /usr/java/jdk1.8.0_181 as J…
在 Spark中为什么task不是按照顺序执行
我在 spark-shell 下面运行一个最简单的 wordcount 程序， val text = spark.read.textFile("/datasets/wordcount_512m.txt") text.flatMap(line => …
如何在DolphinDB database中更快地获取最新状态数据
我的应用场景是每600毫秒一次从1000个设备收集数据，然后将其写入分布式数据库。需要实时数据查询以查询每个设备的最新状态数据。 def createDatabas…
流表用defined(name, VAR|DEF)判断为什么总是返回false
如下代码所示，我想在创建DolphinDB database流表之前先清除流表。 stName="mtopst" if (defined(stName,VAR)){ clearTablePersistence(objByName(st…
在DolphinDB中怎么获取一列值全是NULL的列
假设我有一张DolphinDB内存表如下： t = table(1..3 as a, `a`b`c as b) >t a b 1 a 2 b 3 c 现在想增加一列全是NULL，如下所示： a b col 1 a NULL …
Storm中可不可以使用Websocket发送消息
我在Storm Bolt处理完数据后，想通过Websocket实时发送给前端进行显示处理，可以始终都发送不出去，其他地方发送都可以发送成功，数据可以传递给Webso…
计算持仓成本，有没有高效的方法
如下代码所示，order表的字段id是订单号，price是价格，amount下单数量（+买入，-卖出），当amount为正时，持仓成本=cumsum(amount*price)/cumsum(am…
DolphinDB导出文件时提示No such file or directory，但路径是存在的
如下图所示，我在DolphinDB database中用saveText导出文件时提示文件或目录不存在：但路径是存在的，如下图：我这个目录下 777 权限，为啥提示不存在…
怎么获取DolphinDB表中一天的股票最高价时的信息
假设我有如下表以及记录 sym = `C`MS`MS`MS`IBM`IBM`C`C`C$SYMBOL; price= 49.6 29.46 29.52 30.02 174.97 175.23 50.76 50.32 51.29; qty = 2200 19…
请问一下，dolphindb中delimiter能是tab符么？
请问一下，在DolphinDB database中如下代码： t1=table(1..6 as id,2..7 as v, 3..8 as v1, 4..9 as v2, 5..10 as v3 ); saveText(t1, "trades.txt",…
