public static SchemaHandler getHandler()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandlerFactory.java [30:44]

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

  public static SchemaHandler getHandler(DatabaseType dbType, DataSource dataSource) {
    SchemaHandler handler = null;
    switch (dbType) {
      case DERBY:
        handler = new DerbySchemaHandler(dataSource);
        break;
      case MYSQL:
        handler = new MySQLSchemaHandler(dataSource);
        break;
      default:
        throw new JdbcChannelException("Database " + dbType + " not supported yet");
    }

    return handler;
  }