我编写了一个处理xlsx到csv的nifi定制处理器,并在我的代码中从xlsx生成了一个像这样的字符串csv,但是我不知道如何将其作为csv发送,而其他处理器(如inferavroschema) 来自csv的用户可以将输入流识别为csv。
final Atomicreference<String> value = new Atomicreference<>();
String csvToString= "
name,age,info
javo,23,wasa
pepe,34,lima"
value.set(csvToString);
在我的代码中,我以这种方式发送它,但是当我看到数据出处时,它以内容类型文本出现:
String results = value.get();
if(results != null && !results.isEmpty()){
flowFile = session.putAttribute(flowFile,"csv",results);
}
flowFile = session.write(flowFile,new OutputStreamCallback() {
@Override
public void process(OutputStream out) throws IOException {
out.write(value.get().getBytes());
}
});
session.transfer(flowFile,SUCCESS);