1

我的目标是在 HDFS 上写一个目录。为此，我使用：

  • spring-data-hadoop:2.4.0.RELEASE
  • spring-data-hadoop-store:2.4.0.RELEASE

在我的配置类中，我定义了一个 bean

@Bean
public DataStoreWriter<File> dataStoreWriter() {
        return new AvroPojoDatasetStoreWriter<File>(File.class, datasetRepositoryFactory(), fileInfoDatasetDefinition());
}

在我的服务中，我可以使用这个 bean 来写我想要的：

File myDirectory = new File(myDirectoryPath);
dataStoreWriter.write(myDirectory);

它工作正常，在 HDFS 上我有一个 avro 文件。名称已生成，但我找不到在其上应用文件名策略的解决方案。

我怎样才能修复名称或获取 bean？

4

0 回答 0