private HiveEventSerializer createSerializer()

in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java [217:232]

• 15 lines of code
• 6 McCabe index (conditional complexity)

  private HiveEventSerializer createSerializer(String serializerName)  {
    if (serializerName.compareToIgnoreCase(HiveDelimitedTextSerializer.ALIAS) == 0 ||
        serializerName.compareTo(HiveDelimitedTextSerializer.class.getName()) == 0) {
      return new HiveDelimitedTextSerializer();
    } else if (serializerName.compareToIgnoreCase(HiveJsonSerializer.ALIAS) == 0 ||
            serializerName.compareTo(HiveJsonSerializer.class.getName()) == 0) {
      return new HiveJsonSerializer();
    }

    try {
      return (HiveEventSerializer) Class.forName(serializerName).newInstance();
    } catch (Exception e) {
      throw new IllegalArgumentException("Unable to instantiate serializer: " + serializerName
              + " on sink: " + getName(), e);
    }
  }