2020-08-30 21:33发布
加入QQ群:457200227(SAP S4 HANA技术交流) 群内免费提供SAP练习系统(在群公告中)
专家您好,
要求是拆分邮件并使用max_count'5'批处理记录(id)。
例如:从源头来看," 键"出现了多次(例如25次),并且应将其拆分为5条不同的消息,每条消息均包含5条记录(id)。 如果"密钥"具有26个ID,则第六条消息应多保留一条记录。
来源:
<消息类型>
1 ... 1
0 ...无界
.... 1.1
预期目标:
...
你好
我使用下面的用户定义函数对一个包含分区大小为5的列表进行分区,即外部列表包含5条记录,所有记录均按原始顺序排列。
UDF:
公共无效SplitMessage(String [] id,ResultList结果,容器容器)抛出StreamTransformationException {
AbstractTrace跟踪;
trace = container.getTrace();
int k = 0; trace.addWarning(" ID长度" + id.length);
for(int i = 0; i { if(k <5) { result.addValue(id [i]); } 其他 { k = 0; result.addContextChange(); result.addValue(id [i]); } k ++; } 感谢-Rajesh PS
{
if(k <5)
result.addValue(id [i]);
}
其他
k = 0;
result.addContextChange();
k ++;
感谢-Rajesh PS
您好 Sugata Bagchi Majumder
下面是结构:
是的'id'是'key'的子节点,这是一个异步方案,其中我正在执行多重映射,并使用批处理记录的拆分消息将其发送到BPM流程。
感谢和问候,
Rajesh PS
嗨,Rajesh可以共享示例源和预期的目标XML吗?
ID是Key的子节点吗?
我认为您可以使用Multimapping做到这一点。 但是该接口必须是异步接口。
谢谢
Sugata
最多设置5个标签!
你好
我使用下面的用户定义函数对一个包含分区大小为5的列表进行分区,即外部列表包含5条记录,所有记录均按原始顺序排列。
UDF:
公共无效SplitMessage(String [] id,ResultList结果,容器容器)抛出StreamTransformationException {
AbstractTrace跟踪;
trace = container.getTrace();
int k = 0; trace.addWarning(" ID长度" + id.length);
for(int i = 0; i
{
if(k <5)
{
result.addValue(id [i]);
}
其他
{
k = 0;
result.addContextChange();
result.addValue(id [i]);
}
k ++;
}
感谢-Rajesh PS
您好 Sugata Bagchi Majumder
下面是结构:
是的'id'是'key'的子节点,这是一个异步方案,其中我正在执行多重映射,并使用批处理记录的拆分消息将其发送到BPM流程。
感谢和问候,
Rajesh PS
嗨,Rajesh可以共享示例源和预期的目标XML吗?
ID是Key的子节点吗?
我认为您可以使用Multimapping做到这一点。 但是该接口必须是异步接口。
谢谢
Sugata
一周热门 更多>