Class DDFManager

core/src/main/java/io/ddf/DDFManager.java:80–656

Abstract base class for a DDF implementor, which provides the support methods necessary to implement various DDF interfaces, such as IHandleRepresentations and ISupportML. We use the Dependency Injection, Delegation, and Composite patterns to make it easy for oth

 * possible, in an engine-dependent manner.
 */
public abstract class DDFManager extends ALoggable implements IDDFManager, IHandleSqlLike, ISupportPhantomReference {

  public enum EngineType {
    SPARK,
    JDBC,
    SFDC,
    POSTGRES,
    AWS,
    REDSHIFT,
    BASIC,
    S3,
    HDFS
    ;

    public static EngineType fromString(String str) throws DDFException {
      try {
        return EngineType.valueOf(str.toUpperCase());
      } catch (RuntimeException e) {
        throw new DDFException("Unknown engine type: " + str, e);
      }
    }
  }


  // The engine name, should be unique.
  private UUID uuid = UUID.randomUUID();
  private EngineType engineType;
  // DataSourceDescriptor.
  private DataSourceDescriptor mDataSourceDescriptor;
  // DDFCoordinator.
  private DDFCoordinator mDDFCoordinator;


  public UUID getUUID() {
    return uuid;
  }

  public void setUUID(UUID uuid) {
    this.uuid = uuid;
  }

  public EngineType getEngineType() {
    return engineType;
  }

  public void setEngineType(EngineType engineType) {
    this.engineType = engineType;
  }

  public DDFCoordinator getDDFCoordinator() {
    return mDDFCoordinator;
  }

  public void setDDFCoordinator(DDFCoordinator ddfCoordinator) {
    this.mDDFCoordinator = ddfCoordinator;
  }

  public DataSourceDescriptor getDataSourceDescriptor() {