protected List < MigrationJob > createJobs ( Date startDate , Date endDate , ActiveExecution ae ) throws Exception { List < MigrationJob > ret = new ArrayList < MigrationJob > ( ) ; LOGGER . debug ( "Creating the migrator to setup new jobs" ) ; // We setup a new migration job MigrationJob mj = new MigrationJob ( ) ; mj . setConfigurationName ( getMigrationConfiguration ( ) . getConfigurationName ( ) ) ; mj . setScheduledDate ( getNow ( ) ) ; mj . setGenerated ( true ) ; mj . setStatus ( MigrationJob . STATE_AVAILABLE ) ; mj . setConsistencyChecker ( new MigrationJob . ConsistencyChecker ( ) ) ; mj . getConsistencyChecker ( ) . setJobRangeBegin ( ClientConstants . getDateFormat ( ) . format ( startDate ) ) ; mj . getConsistencyChecker ( ) . setJobRangeEnd ( ClientConstants . getDateFormat ( ) . format ( endDate ) ) ; mj . getConsistencyChecker ( ) . setConfigurationName ( mj . getConfigurationName ( ) ) ; Migrator migrator = createMigrator ( mj , ae ) ; mj . setQuery ( migrator . createRangeQuery ( startDate , endDate ) ) ; // At this point, mj.query contains the range query LOGGER . debug ( "Migration job query:{}" , mj . getQuery ( ) ) ; ret . add ( mj ) ; return ret ; }
Create a migration job or jobs to process records created between the given dates . startDate is inclusive end date is exclusive