Исправить имя файла Avro с помощью весенних данных hadoop
Моя цель - написать каталог на HDFS. Для этого я использую:
- весна-данных Hadoop:2.4.0.RELEASE
- весна-данных Hadoop-магазин: 2.4.0.RELEASE
В моем классе конфигурации я определяю боб
@Bean
public DataStoreWriter<File> dataStoreWriter() {
return new AvroPojoDatasetStoreWriter<File>(File.class, datasetRepositoryFactory(), fileInfoDatasetDefinition());
}
В моем сервисе я могу использовать этот боб, чтобы написать то, что я хочу:
File myDirectory = new File(myDirectoryPath);
dataStoreWriter.write(myDirectory);
Работает нормально, на HDFS у меня есть файл avro. Имя сгенерировано, и я не могу найти решение, чтобы применить к нему стратегию имени файла.
Как я могу исправить имя или получить бин?