在 spring XD 中作为源和接收器的文件

Question

我想在我的 spring XD 流定义中使用文件作为源和接收器。我的用例是读取一个大文件并将其拆分为多个小文件。我想用流定义来做到这一点，而不是使用自定义模块

我写的流定义是

stream create inputStream8 --definition "file --dir=C:/springXD/ds_data --outputType=text/plain | splitter --expression=T(java.util.Arrays).copyOfRange(payload.split('\n'),1,3) | file " --deploy

我收到类似

的错误

标签文件应该是唯一的，但模块文件在位置 0 和位置 2。

关于如何标记这些模块有什么建议吗？

没有自定义模块的任何其他分割大的方法吗？

Answer 1

见the documentation about labels。

Labels are especially useful (and required) for disambiguating when multiple modules of the same name are used:

file | ... | outfile: file ...

在 spring XD 中作为源和接收器的文件

file as source as well as sink in spring XD

java

spring

spring-integration

spring-xd