Alink是一个专为实时数据处理而设计的机器学习框架,它通过组件的聚合成组与资源优化,实现高效的数据处理和资源使用。其创新在于能够批量执行任务,减少不必要的数据存储操作,从而在实时计算场景中提供卓越的性能表现。
简介
Alink是阿里云PAI团队基于实时计算Flink研发的新一代机器学习算法框架及组件库。除了具备普通组件的用法外,Alink组件还支持聚合成组,通过对组进行资源配置,成组后的Alink节点在运行时能够批量执行,并避免中间数据落盘,从而提升执行效率和资源利用率。
在Designer中,支持多种Alink组件,这些组件通过紫色标记进行标识,如下所示:
Designer 左侧组件面板中可用的 Alink 组件包括 协同过滤etrec、FM训练、FM预测、swing训练、swing推荐、graphSage、DeepFM,以及异常检测类组件(如 IForest异常检测、局部异常因子异常检测、One-Class SVM异常检测),均带有紫色标记以区分普通组件。
Alink组件使用说明
除了基础组件用法外,Alink组件支持聚合成组。当系统检测到画布中有可以成组运行的Alink节点时,您也可以单击画布上方的
或通过Shift+鼠标左键,选择多个Alink节点,在空白处单击右键,选择选中节点成组,进行Alink组件聚合,然后单击
,对Alink组进行资源配置。
在自定义实验配置对话框中,可配置Alink组名称、Alink组执行资源类型、Worker数量(默认为2)和每个Worker占用的内存(M)(默认为4096)。
说明
Alink组的配置优先级高于组内每个Alink节点的单独配置。
相 关文档
该文章对您有帮助吗?