我有一个文件,其中包含txt格式的数据,文件中的每一行都是1条记录。我正在使用拆分文本处理器将流文件拆分成1条记录/文件。 我想从记录中提取一个子串。我需要从开始到第n个索引获取一个子串。 e.g.
'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ012345678910'
result flowfile for first 10 chars= abcdefghij ? ? 我在这里使用默认设置,除非我尝试添加一些在线论坛中提到的属性(att1)。这没用的。 请帮帮我
我有5个处理器( have a value)=>processor2( processor1(processor1) => calculate e=d*b)。我将在processor4中使用processor1值,在processor5中使用processor2值。我需要将processor1输入/输出结果存储在高速缓存中,以便在处理器n中使用。如果有处理器,请建议我如何实现这一点,或者我可以通过bash脚本实现这一点?
在我的当前流中,我有一个情况,我想在流文件中评估某些属性。这是我的流文件的当前结构:
{
Attribute1: Value
Attribute2: Value
.
Attribute k: Value
.
}
例如,如果属性2是长度为9的整数,如果不将属性k的值设置为“无效”,则计算它。
我可以使用哪个处理器或处理器组合(最多为2)来完成此操作?另外,您能为我刚才提到的情况编写底层的表达式语言吗?因为我对这一技术还很陌生,我需要尽快完成它。
在这段代码中,我想将lastDate保存在数组中,并使用它来增加startDate和endDate的属性值automatically.but,它不生成流文件。,我试图修复它,但它不能创建浮点,我应该更改什么?
var OutputStreamCallback = Java.type("org.apache.nifi.processor.io.OutputStreamCallback");
var StandardCharsets = Java.type("java.nio.charset.StandardCharsets");
Date.prototype.
我希望有人能帮助我。我正在尝试学习Apache,方法是执行一些项目,其中我有以下格式的json文件:
{
"network": "reddit",
"posted": "2021-12-24 10:46:51 +00000",
"postid": "rnjv0z",
"title": "A gil commission artwork of my friends who are in-game couples!",
"text":
我有一个具有3个属性a,b,c的flowfile,我想创建两个新属性a_b_hash,c_hash。
a_b_hash = hash of (value of a + '_' + value of b)
c_hash = hash of c
最后,我需要5个属性a、b、c、a_b_hash、c_hash。a,b,c不变。
我尝试了不同的组合,但无法生成哈希。有些排列工作,但我不知道它是否产生正确的有。
更新
我创建了下面的模板并运行它。我希望a_hash和c_hash具有相同的值,a和c具有相同的值。
<?xml version="1.0" encodi
我有一个流程,我必须等待确切的12个文件一次。
所以我写了一些代码
getHDFS ->通知->等待->进行一些处理。
通知具有以下配置
Release Signal Identifier = eredee_45rgfyWQQWQ
Signal Counter Name = cntr_for_run
Signal Counter Delta = 1
Signal Buffer Count = 1
wait有以下配置
Release Signal Identifier = eredee_45rgfyWQQWQ
Target Signal Count = 12
Signal Co
我有数据需要比较月份的数据,如果是前一个月,那么它应该插入,否则不。
示例:
23.12.2016 12:02:23,Koji,24
22.01.2016 01:21:22,Mahi,24
现在我需要得到第一列数据(23.12.2016 12:02:23),然后得到月份(12)。
和当月前比较起来.
If current month is 'JAN_2017',then get before of 'JAN_2017' it should be 'Dec_2016'
第一排,
将这一“2016年12月”与数据月份“Dec_2016”(2016年1
我正在阅读C#中使用catch(..) when (..)的过滤器表达式,但是我找不到任何关于在计算表达式时抛出异常会发生什么的内容。我试着翻阅了文档和规范,但要么找不到它们,要么没有提到它们。因此,我编写了一个小程序来检查当我从when(..)抛出时会发生什么。我把它放到上了
try {
Console.WriteLine("Test(): Inside Test()");
throw new Exception("thrown from Test()");
} catch (Exception) when (AlwaysThrow()) {