Re: Is there any options to control the file names in file sink

2024-03-20 Thread Yanfei Lei
Hi Lasse, If the datastream job is used, you can try setting `OutputFileConfig` for file sink, something like[1]: ``` OutputFileConfig config = OutputFileConfig .builder() .withPartPrefix("prefix") .withPartSuffix(".ext") .build(); FileSink> sink = FileSink .forRowFormat((new Path(outputPath)

Is there any options to control the file names in file sink

2024-03-20 Thread Lasse Nedergaard
Hi. Anyone know if it’s possible to control the file names eg change the uuid file names and extensions to something else. I know I can control the path but I would like to be able to set the file name and the extension based on the data in the stream. So I can’t use any general pre or postfix