protected void finishWrite()

in dbeam-core/src/main/java/com/spotify/dbeam/avro/JdbcAvroIO.java [218:227]

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

    protected void finishWrite() throws Exception {
      LOGGER.info("jdbcavroio : Closing connection, flushing writer...");
      if (connection != null) {
        connection.close();
      }
      if (dataFileWriter != null) {
        dataFileWriter.close();
      }
      LOGGER.info("jdbcavroio : Write finished");
    }