DolphinDB的map-reduce函数mr函数如何使用?可以给一个例子吗?

如题,DolphinDB的map-reduce函数mr函数如何使用?可以给一个例子吗?

请先 登录 后评论

1 个回答

Jason Tang - 时序数据库技术支持

以查询一个分区表的所有股票值为例:

ds=sqlDS(<select SecurityID from loadTable( "dfs://SH_TSDB_snapshot_MultiColumn", "snapshot") where date(DateTime)=2021.12.01>)
def disctcode(t){
	return select distinct(SecurityID)  as SecurityID from t
}
data = distinct(mr(ds, disctcode, ,unionAll{,false}).SecurityID)
请先 登录 后评论