一部のデータを HDFS に保存するには、HDFS シンクを使用する必要があります。ストリーム定義を作成するとき、「ディレクトリ」プロパティを使用して、ファイルを保存する hdfs ディレクトリを指定できます。ただし、このユースケースでは、ディレクトリをタイムスタンプに基づいて動的にする必要があります。HDFSシンクのディレクトリプロパティでSpELを使用して、ヘッダーからタイムスタンプを抽出できるかどうか考えていましたか?
ありがとう!!
ロドリゴはすでにこれを知っていますが、このスレッドをチェックしている他の人は、参照ドキュメントのこのセクションで「partitionPath」を検索して、新しい機能の説明を参照してください: https://github.com/spring-projects/spring-xd /wiki/シンク#hadoop-hdfs