文件名称:
面向函数的数据处理框架Canal.js.zip
开发工具:
文件大小: 45kb
下载次数: 0
上传时间: 2019-07-19
详细说明： Canal.js 是一款面向函数的数据处理框架，力图在 js 中提供类似于 spark 的编程风格。Common TransformCanal.of([ 4, 0, 3, 5, 2, 4 ]) .filter(function(d) { return d > 2; }) .distinct() .sortWith() .map(function(d) { return [ d % 2, d ]; }) .collect()[1, 3] [0, 4] [1, 5]Group OperationCanal.of([ 4, 0, 3, 5, 2, 4 ]) .filter(function(d) { return d > 2; }) .dis tinct() .sortWith() .map(function(d) { return [ d % 2, d ]; }) .groupBy() .collect()[0, [4 ]] [1, [3,5]]Join OperationCanal.of([ 4, 0, 3, 5, 2, 4 ]) .filter(function(d) { return d > 2; }) .distinct() .sortWith() .map(function(d) { return [ d % 2, d ]; }) .groupBy() .join(Canal.of([ 0, 1, 2 ]) .map(function(d) { return [ d, d ]; })) .collect()[0, [[4 ], 0]] [1, [[3,5], 1]]Window Operationfunction sum(unpacker) { return function(rows, begin, end, current) { return Canal.of(rows, begin, end) // .unpack(unpacker) // .reduce((a, b) => a b).get(); }; } var result = Canal.of([ {"id":1,"sex":1,"grp":0,"sal":3032}, {"id":2,"sex":1,"grp":1,"sal":2153}, {"id":3,"sex":2,"grp":0,"sal":2545}, {"id":4,"sex":1,"grp":1,"sal":1894} ]).toRows().window( Canal.item(sum(d=>d.id)) .partBy(d=>d.grp) .orderBy(d=>d.sex), Canal.item(sum(d=>d.sal)) .partBy(d=>d.grp, d=>d.sex), Canal.item(sum(d=>d.sal)) .partBy(d=>d.grp) .orderBy(d=>d.sal) .between(null, 0) ).collect();[ [{"id":3,"sex":2,"grp":0,"sal":2545}, 4, 2545, 2545], [{"id":1,"sex":1,"grp":0,"sal":3032}, 1, 3032, 5577], [{"id":4,"sex":1,"grp":1,"sal":1894}, 6, 4047, 1894], [{"id":2,"sex":1,"grp":1,"sal":2153}, 6, 4047, 4047] ] 标签：Canal
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
相关搜索:
