Мой код (внутри основной функции для создания конвейера): -
outCollection.apply("WriteToFile",
TextIO.write().to(path).withHeader(header)
.withFooter(footer).withoutSharding());
Текущее поведение - запись файла по заданному пути с верхним и нижним колонтитулами.Я хочу иметь возможность указать конвейер, чтобы не записывать файл в этом месте, когда outCollection является пустым PCollection.
Я пошел к SDK код .Там я нашел параметр с именем emptyDestination для записи файлов, когда PCollection пусто, но устарело.Они предлагают использовать FileIO.Write с Sink, но я не могу определить функцию для моего варианта использования.Я где-то скучаю?
Есть ли идеи у людей, знакомых с базой кода?