aclnnScatterPaKvCache
产品支持情况
产品 | 是否支持 |
---|---|
[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object] | √ |
[object Object]Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件[object Object] | √ |
[object Object]Atlas 200I/500 A2 推理产品[object Object] | × |
[object Object]Atlas 推理系列产品 [object Object] | × |
[object Object]Atlas 训练系列产品[object Object] | × |
功能说明
更新KvCache中指定位置的key和value。
输入输出支持以下场景:
场景一:
[object Object]场景二:
[object Object]其中k_head_size与v_head_size 可以不同,也可以相同。
场景三:
[object Object]
上述场景根据构造的参数来区别,符合第一种入参构造走场景一,符合第二种构造走场景二,符合第三种构造走场景三。场景一、场景二没有compressLensOptional、seqLensOptional、compressSeqOffsetOptional这三个可选参数。
[object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]、[object Object]Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件[object Object]:仅支持场景一。
函数原型
每个算子分为undefined,必须先调用“aclnnScatterPaKvCacheGetWorkspaceSize”接口获取计算所需workspace大小以及包含了算子计算流程的执行器,再调用“aclnnScatterPaKvCache”接口执行计算。
aclnnStatus aclnnScatterPaKvCacheGetWorkspaceSize(const aclTensor *key, const aclTensor *keyCacheRef, const aclTensor *slotMapping, const aclTensor *value, const aclTensor *valueCacheRef, const aclTensor *compressLensOptional, const aclTensor *compressSeqOffsetOptional, const aclTensor *seqLensOptional, char *cacheMode, uint64_t *workspaceSize, aclOpExecutor **executor)
aclnnStatus aclnnScatterPaKvCache(void *workspace, uint64_t workspaceSize, aclOpExecutor *executor, aclrtStream stream)
aclnnScatterPaKvCacheGetWorkspaceSize
参数说明:
- key(aclTensor*,计算输入):Device侧的aclTensor,支持3维或4维,待更新的key值,当前step多个token的key,数据类型支持FLOAT16、FLOAT、BFLOAT16、INT8、UINT8、INT16、UINT16、INT32、UINT32、HIFLOAT8、FLOAT8_E5M2、FLOAT8_E4M3FN,undefined支持ND。
- keyCacheRef(aclTensor*,计算输入/输出):Device侧的aclTensor,只支持4维,需要更新的key cache,当前layer的key cache,数据类型和格式与key一致。
- slotMapping(aclTensor*,计算输入):Device侧的aclTensor,每个token key或value在cache中的存储偏移,数据类型支持INT32、INT64,undefined支持ND。
- value(aclTensor*,计算输入):Device侧的aclTensor,支持3维或4维,shape与key一致,待更新的value值,当前step多个token的value,数据类型和格式与key一致。
- valueCacheRef(aclTensor*,计算输入/输出):Device侧的aclTensor,只支持4维,shape与keyCacheRef一致,需要更新的value cache,当前layer的key cache,数据类型和格式与key一致。
- compressLensOptional(aclTensor*,可选计算输入):Device侧的aclTensor,压缩量,数据类型与slotMapping一致,undefined支持ND。
- compressSeqOffsetOptional(aclTensor*,可选计算输入):Device侧的aclTensor,每个batch每个head的压缩起点,数据类型与slotMapping一致,undefined支持ND。
- seqLensOptional(aclTensor*,可选计算输入):Device侧的aclTensor,每个batch的实际seqLens,数据类型与slotMapping一致,undefined支持ND。
- cacheMode(char*,计算输入):host侧的char* , 表示keyCacheRef和valueCacheRef的数据格式。
- [object Object]Atlas A3 训练系列产品/Atlas A3 推理系列产品[object Object]、[object Object]Atlas A2 训练系列产品/Atlas 800I A2 推理产品/A200I A2 Box 异构组件[object Object]:当传空指针或"PA_NZ"时,仅支持FRACTAL_NZundefined。
- workspaceSize(uint64_t*,出参):返回用户需要在Device侧申请的workspace大小。
- executor(aclOpExecutor**,出参):返回op执行器,包含了算子计算流程。
返回值:
aclnnStatus:返回状态码,具体参见undefined。
[object Object]
aclnnScatterPaKvCache
参数说明:
- workspace(void*, 入参):在Device侧申请的workspace内存地址。
- workspaceSize(uint64_t, 入参):在Device侧申请的workspace大小,由第一段接口aclnnScatterPaKvCacheGetWorkspaceSize获取。
- executor(aclOpExecutor*, 入参):op执行器,包含了算子计算流程。
- stream(aclrtStream, 入参):指定执行任务的Stream。
返回值:
aclnnStatus:返回状态码,具体参见undefined。
约束说明
- 输入参数不支持非连续;
- key、value、keyCacheRef、valueCacheRef的数据类型必须一致;
- slotMapping、compressLensOptional、compressSeqOffsetOptional、seqLensOptional的数据类型必须一致;
- slotMapping的值范围[0,num_blocks*block_size-1],且slotMapping内的元素值保证不重复,重复时不保证正确性;
- 当key和value都是3维,则key和value的前两维shape必须相同;
- 当key和value都是4维,则key和value的前三维shape必须相同,且keyCacheRef和valueCacheRef的第三维必须是1;
- 当key和value是4维时,compressLensOptional、seqLensOptional为必选参数;当key和value是3维时,compressLensOptional、compressSeqOffsetOptional、seqLensOptional为可选参数;
- 当key和value都是4维时,slotMapping是二维,且slotMapping的第一维值等于key的第一维为batch,slotMapping的第二维值等于key的第三维为num_head(对应场景三);
- 当key和value都是4维时,seqLensOptional是一维,且seqLensOptional的值等于key的第一维为batch(对应场景三);
- seqLensOptional和compressLensOptional里面的每个元素值必须满足公式:reduceSum(seqLensOptional[i] - compressLensOptional[i]) <= num_blocks * block_size (对应场景三)。
调用示例
示例代码如下,仅供参考,具体编译和执行过程请参考undefined。