Class DefaultCortexJobRegistry

  • All Implemented Interfaces:
    CortexJobRegistry

    public class DefaultCortexJobRegistry
    extends java.lang.Object
    implements CortexJobRegistry
    CortexJobRegistry implementation
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      BuildProfileJob buildProfile​(java.lang.String project, java.lang.String profileSchema, CortexContext cortexContext)
      Creates an instance of the BuildProfileJob to run with the supplied parameters
      IngestDataSourceJob ingestDataSource​(java.lang.String project, java.lang.String dataSource, CortexContext cortexContext)
      Creates an instance of the IngestDataSourceJob to run with the supplied parameters
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • DefaultCortexJobRegistry

        public DefaultCortexJobRegistry()
    • Method Detail

      • ingestDataSource

        public IngestDataSourceJob ingestDataSource​(java.lang.String project,
                                                    java.lang.String dataSource,
                                                    CortexContext cortexContext)
        Description copied from interface: CortexJobRegistry
        Creates an instance of the IngestDataSourceJob to run with the supplied parameters
        Specified by:
        ingestDataSource in interface CortexJobRegistry
        Parameters:
        project - the project
        dataSource - the DataSource name
        cortexContext - the context
        Returns:
        instance of IngestDataSourceJob
      • buildProfile

        public BuildProfileJob buildProfile​(java.lang.String project,
                                            java.lang.String profileSchema,
                                            CortexContext cortexContext)
        Description copied from interface: CortexJobRegistry
        Creates an instance of the BuildProfileJob to run with the supplied parameters
        Specified by:
        buildProfile in interface CortexJobRegistry
        Parameters:
        project - the project
        profileSchema - the ProfileSchema name
        cortexContext - the context
        Returns:
        instance of BuildProfileJob