TimeBatch

功能介绍

TimeBatch功能是基于UDF为前提的。

正常模型每次处理一个数据，当需要一次处理一批数据时，就需要将这批数据组成一个batch，最基本的batch方式是将这批N个数据直接拼接，然后shape前加N，而某些场景需要将某段或者某几段时间数据组成一个batch，并且按特定的维度拼接，则可以通过使用TimeBatch功能来组batch。

在ASR(Automatic Speech Recognition)自动语音识别场景下，存在按定长时间段组batch或按时间分段（时间不连续）组整批batch两种诉求，可以通过TimeBatch实现。

使用方法

用户在Dataflow构图时通过给FlowNode的输入设置属性来添加TimeBatch功能。示例如下。

TimeBatch time_batch = {};
// 按需求设置time_batch中各属性的值
time_batch.time_window = 10;
time_batch.batch_dim = 5;
time_batch.drop_remainder = true;
DataFlowInputAttr flow_attr = {DataFlowAttrType::TIME_BATCH, &time_batch};
std::vector<DataFlowInputAttr> flow_attrs = {flow_attr};
// 然后通过FlowNode的MapInput设置
FlowNode::MapInput(xx, xx, xx, flow_attrs);

属性名称	数据类型	取值说明
time_window	int64_t	整型(单位ms)，当值> 0时表示按该时间窗来组batch，当值为-1时表示按时间分段来组batch，其它值报错。
batch_dim	int64_t	只有设置了time_window时，该参数才生效。取值范围[-1,shape维度]。默认为-1表示数据输出shape会在第0维添加一个batch维。 shape维度>batch_dim>=0时表示按某个维度组batch。 batch_dim>shape维度或者<-1时报错。
drop_remainder	bool	只有设置了time_window时，该参数才生效。仅在time_window>0时生效，选择不足time_window时是否丢弃，默认false不丢弃。true则丢弃。举例如下：假如time_window=5ms，输入数据时长为3ms，则： drop_remainder不配置或者配置为false时，不丢弃输入数据。 drop_remainder配置为true时如果输入数据未携带EOS或者SEG，会一直等待，不丢弃数据。如果输入数据只携带了SEG，则丢弃数据。如果输入数据携带了EOS标记，则丢弃输入数据，只传递EOS标记。
time_interval	int64_t	未使能
timeout	int64_t	未使能
flag	int32_t	未使能
padding	bool	未使能

使用注意事项

当前Batch特性无法做负荷分担，因此如果使用2P环境，需要在ge初始化时添加{"ge.exec.logicalDeviceClusterDeployMode", "SINGLE"}, {"ge.exec.logicalDeviceId", "[0:0]"}。其中logicalDeviceId可以是[0:0]，也可以是[0:1]，详细介绍如下。

logical_device_cluster_deploy_mode为SINGLE时，用于指定模型部署在某个指定的设备上。

配置格式：[node_id:device_id]

node_id：昇腾AI处理器逻辑id，从0开始，表示资源配置文件中第几个设备。
device_id：昇腾AI处理器物理id。

父主题： DataFlowInputAttr结构体