private Schema createSchema()

in dbeam-core/src/main/java/com/spotify/dbeam/jobs/JdbcAvroJob.java [146:152]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  private Schema createSchema(final Connection connection) throws Exception {
    if (this.jdbcExportArgs.inputAvroSchema().isPresent()) {
      return this.jdbcExportArgs.inputAvroSchema().get();
    } else {
      return BeamJdbcAvroSchema.createSchema(this.pipeline, jdbcExportArgs, connection);
    }
  }