hadoop - spring xd stream definition dynamic parameters -


we need use hdfs sink store data in hdfs. when creating stream definition, can use "directory" property specify hdfs directory want save file. however, in our use case want directory dynamic based on timestamp. thinking if it's possible maybe use spel in directory property of hdfs sink maybe extract timestamp header?

thanks!!

rodrigo knows this, else checking out thread, see explanation of new functionality searching "partitionpath" under section of reference doc: https://github.com/spring-projects/spring-xd/wiki/sinks#hadoop-hdfs


Comments

Popular posts from this blog

c++ - How to add Crypto++ library to Qt project -

jQuery Mobile app not scrolling in Firefox -

How to use vim as editor in Matlab GUI -