0

我们需要使用 HDFS sink 在 HDFS 中存储一些数据。创建流定义时，我可以使用“目录”属性来指定要保存文件的 hdfs 目录。但是，在我们的用例中，我们希望目录是基于时间戳的动态目录。我在想是否有可能在 HDFS 接收器的目录属性中使用一些 SpEL 来从标头中提取时间戳？

谢谢！！

4

1 回答 1

1

Rodrigo already knows this, but for anyone else checking out this thread, see the explanation of the new functionality by searching for "partitionPath" under this section of the reference doc: https://github.com/spring-projects/spring-xd/wiki/Sinks#hadoop-hdfs

于 2014-06-16T14:05:30.657 回答