public CodecFactory getCodecFactory()

in dbeam-core/src/main/java/com/spotify/dbeam/args/JdbcAvroArgs.java [50:59]

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

  public CodecFactory getCodecFactory() {
    if (avroCodec().equals("snappy")) {
      return CodecFactory.snappyCodec();
    } else if (avroCodec().startsWith("deflate")) {
      return CodecFactory.deflateCodec(Integer.valueOf(avroCodec().replace("deflate", "")));
    } else if (avroCodec().startsWith("zstandard")) {
      return CodecFactory.zstandardCodec(Integer.valueOf(avroCodec().replace("zstandard", "")));
    }
    throw new IllegalArgumentException("Invalid avroCodec " + avroCodec());
  }