在使用Spring批处理实现标题之前,我必须在CSV文件中添加一行免责声明。例如,下面是我预期的CSV文件:
免责声明XYZ。。。Col1 Col2 Col3 abc efg pqr
目前,我正在使用FlatFileItemWriter和FlatFileHeaderCallBack创建CSV文件,并在其中写入标题及其相应的值。
但我不能添加免责声明,然后按照上面显示的标题。
下面是我的代码一瞥:
stepWriter.setHeaderCallback(new FlatFileHeaderCallback()
public void writeHeader(Writer writer) throws IOException{`
writer.write(disclaimer);
writer.write(“Col1”, “Col2”,”Col3”);
}
});
但根据上述代码,实际的CSV如下所示:
免责声明XYZ Col1 Col2 Col3
根据您的描述,免责声明XYZ
是我的标题的一部分,因此我会保持简单,并将标题回调更新为如下内容:
stepWriter.setHeaderCallback(new FlatFileHeaderCallback() {
@Override
public void writeHeader(Writer writer) throws IOException {
writer.write("Disclaimer-XYZ");
writer.write(System.lineSeparator());
writer.write("Col1 Col2 Col3");
}
})
这应该打印:
Disclaimer-XYZ
Col1 Col2 Col3
...
问题内容: 如何在csv中编写多头标头,以便第二个标头值应来自数据库 //预期的输出 //以下是用于弹簧批处理写入csv的代码段 问题答案: 您可以在中执行查询,并将结果附加到标题的第一行。
问题内容: 我有一个带有1000个json对象的json文件。有什么办法可以在每个json文档之前添加标题行?有没有最简单的方法? 示例:我有1000个这样的对象 我想为每个json对象添加如下所示的索引标头,以便可以在Elasticsearch Bulk api中使用 问题答案: 如果您愿意利用Logstash,则无需修改文件,而可以简单地逐行读取文件,并使用利用Bulk API 的输出将其流式
几个月前,我用Spring Batch制作了一个项目。 该项目工作正常,包括JobExecution决策器的实现 这使fini仅与Spring Batch配合使用。 现在我必须将其用于Spring Boot批处理。在决策步骤之前,所有流程都运行良好。其中,我返回了良好的FlowExecutionStatus,但我不知道为什么,作业以“失败”状态完成。 有人知道为什么不工作了? 谢谢
我刚刚意识到,一旦在 Kafka 主题上收到的消息会丢失标题。有没有办法在将消息发布到 Kafka 主题然后在消费者处阅读之前向消息添加标头?我正在使用Java 11,Spring Cloud Hoxton.SR6,Spring 2.2.4,kafka_2.13-2.6.0。提前感谢!
我有一些火花代码来处理csv文件。它对其进行一些转换。我现在想将此RDD保存为csv文件并添加一个标头。此RDD的每一行都已正确格式化。 我不知道怎么做。我想用头字符串和我的RDD进行联合,但头字符串不是RDD,因此无法工作。
我正在使用Spring Batch Admin从我的主项目的批处理模块中启动批处理。 在Spring batch Admin项目的依赖项中,将批处理模块编译为JAR addedstrong文本,如下所示: 因为我在一个reader类上添加了“@stepscope”,所以在部署Spring Batch Admin时,我会遇到以下错误 但是我没有找到如何使用类似的声明来防止Spring Batch A