Simon Dahlbacka
08/21/2023, 8:32 AMTableEnvironment.executeSql but I want to get some configuration from a wasbs:// file. The file itself is at max some kBs large, but the only way I found how to do it I end up with a FileSource: i.e.
FileSource<String> source =
FileSource.forRecordStreamFormat(
new TextLineInputFormat("UTF-8"), new Path(...)
.build();
. Can I somehow get the contents as a plain String instead? Running flink 1.16.1 at the moment, but if need be I can upgrade.Simon Dahlbacka
08/21/2023, 11:22 AMPath sqlPath = new Path(...);
FileSystem fs = sqlPath.getFileSystem();
FSDataInputStream inputStream = fs.open(sqlPath);
InputStreamReader reader = new InputStreamReader(inputStream);
String script = new BufferedReader(reader).lines().parallel().collect(Collectors.joining("\n"));