2

我正在尝试开发一个UDF（队列的所有值），它将字符串作为输入包含字段和字段值的管道（|）分隔符。此外，字符串同时包含 Header 和 Detail。

标题字段将在一行中出现一次，并在“N”次中出现详细信息。

下面是输入字符串::

Headerfield1|fieldValue1|Headerfield2|fieldValue2|Headerfield3|fieldValue3|Headerfield4|fieldValue4|Headerfield5|fieldValue5|Headerfield6|fieldValue6|Itemfield1|fieldvalue1|Itemfield1|fieldvalue1|Itemfield2|fieldvalue2|Itemfield3|fieldvalue3|Itemfield4|fieldvalue4|Itemfield1-1|fieldvalue1-1|Itemfield2-1|fieldvalue1-2|Itemfield3-1|fieldvalue3-1|Itemfield4-1|fieldvalue4-1|Itemfield1-2|fieldvalue1-2|Itemfield2-2|fieldvalue2-2|Itemfield3-2|fieldvalue3-2|Itemfield4-2|fieldvalue4-2|

在上面的字符串中，Headerfield1 是一个字段，其对应的值是 fieldValue1

在 UDF 中，我们在变量输入中传递输入字符串，在变量字段中传递必填字段。

我正在尝试传递字段名称并期望其相应的字段值作为输出

Below is the UDF

public void StringSplit(String[] input, String[] field, ResultList result, Container container) throws StreamTransformationException{

String str = input.toString();
String tokens[] = str.split("\\|");
Map<String, String>tokensMap = new HashMap();
  int j =0;
  for(int i =0; i <tokens.length ; i++)
  {
    if(j == i)
    {
     String key = tokens[i].toString();
       if (key.contains("-"))
     {
     String key2 = key.substring(0, key.indexOf("-"));
     if(tokensMap.containsKey(key2))
     {
     tokensMap.put(key2, tokensMap.get(key2)+","+tokens[i+1].toString());
     }
     else
     {
     tokensMap.put(key.substring(0, key.indexOf("-")),tokens[i+1].toString());
     }
     }
     else
     {
     tokensMap.put(tokens[i].toString(),tokens[i+1].toString());
     }
     j = i+2;
    }
   }
  String[] result1 = tokensMap.get(field).split(",");
  for (int i = 0; i < result1.length; i++)
{
if (result1[i].equals("") || result1[i].equals(null) )
result.addSuppress();
else
      result.addValue(result1[i]);  
}
}

此 UDF 接受输入字符串并使用 pipe(|) 拆分并将其保存在令牌中，然后将其添加到 tokensMap。最后获取所需字段并存储到 result1 中，并使用 for 循环添加到结果列表中。我在下面收到错误。

错误

com.sap.xi.tf 类中的异常：[java.lang.ArrayIndexOutOfBoundsException:]。

附上错误日志屏幕截图。粉煤灰。

请检查错误并建议我需要更改的地方。

提前致谢

谢谢你，Chakradhar N！

4

0 回答 0