public PositionOutputStream newOutputStream()

in src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java [68:81]

13 lines of code
3 McCabe index (conditional complexity)


    public PositionOutputStream newOutputStream(Path path, boolean overwrite) throws IOException {
        TrinoOutputFile trinoOutputFile =
                trinoFileSystem.newOutputFile(Location.of(path.toString()));

        try {
            return new PositionOutputStreamWrapper(trinoOutputFile.create());
        } catch (FileAlreadyExistsException e) {
            if (overwrite) {
                trinoFileSystem.deleteFile(Location.of(path.toString()));
                return new PositionOutputStreamWrapper(trinoOutputFile.create());
            }
            throw e;
        }
    }