Method get

core/src/main/java/io/ddf/DDFManager.java:247–273

(EngineType engineType, DataSourceDescriptor dataSourceDescriptor)

  }

  public static DDFManager get(EngineType engineType, DataSourceDescriptor dataSourceDescriptor) throws DDFException {
    if (engineType == null) {
      engineType = EngineType.fromString(ConfigConstant.ENGINE_NAME_DEFAULT.toString());
    }

    String className = Config.getValue(engineType.name(), ConfigConstant.FIELD_DDF_MANAGER);
    // if (Strings.isNullOrEmpty(className)) return null;
    if (Strings.isNullOrEmpty(className)) {
      throw new DDFException("ERROR: When initializaing ddfmanager, class " +
              className + " not found");
    }

    try {
      Class[] classType = new Class[2];
      classType[0] = dataSourceDescriptor.getClass();
      classType[1] = engineType.getClass();

      DDFManager manager = (DDFManager) Class.forName(className).getDeclaredConstructor(classType)
          .newInstance(dataSourceDescriptor, engineType);
      UUID uuid = UUID.randomUUID();
      manager.setUUID(uuid);
      return manager;
    } catch (Exception e) {

      throw new DDFException(e);
    }
  }

  public static DDFManager get(EngineType engineType, String uri) throws DDFException {
    Preconditions.checkArgument(engineType != null, "Engine type cannot be null");