如何解决Streamsets Jython评估程序
我需要有关如何检查记录的所有字段(如果它包含某个字符串)以及如何编写具有该字符的标头属性的代码。请参见下面的代码:
for record in records:
if record.value == "":
record.attributes["DATA"] = "BAD"
sdc.output.write(record)
else:
record.attributes["DATA"] = "GOOD"
sdc.output.write(record)
如果有人知道另一种方法可以做到这一点!!! record.values ['/ *']对于我无法获取所有列。
解决方法
对于任何面临相同问题的人,这可能会有所帮助!
for record in records:
for key in record.value:
if record.value[key] == "":
record.attributes["DATA"] = key
sdc.output.write(record)
,
这是另一种紧凑的编写方式。
for (key,val) in record.value.iteritems():
if val == "some_string_value":
record.attributes["DATA"] = "some_header_value"
sdc.output.write(record)
干杯, 短跑
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。