private void dumpFile()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [205:216]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    private void dumpFile() throws IOException {
        SourceFile temp = currentFile;
        currentFile = null;
        if (temp != null) {
            countingStream.close();
            currentFileDescriptor = null;
            boolean deleted = temp.file.delete();
            if (!deleted) {
                log.warn("Couldn't delete temporary file. File exists: {}", temp.file.exists());
            }
        }
    }