@Test public void phase_epilogue() throws Exception { ProfileBuilder prf = new ProfileBuilder(folder.getRoot()); ExecutionTask task = prf.task(); task.executePhase("batch", "testing", "f-pro", ExecutionPhase.EPILOGUE); List<Record> results = SerialExecutionTracker.get(prf.trackingId); verifyPhaseOrder(results); assertThat(results.size(), is(1)); List<Record> records = phase(results, "testing", ExecutionPhase.EPILOGUE); assertThat(records, is(results)); }
public void executePhase( String batchId, String flowId, String executionId, ExecutionPhase phase) throws InterruptedException, IOException { if (batchId == null) { throw new IllegalArgumentException("batchId must not be null"); } if (flowId == null) { throw new IllegalArgumentException("flowId must not be null"); } if (executionId == null) { throw new IllegalArgumentException("executionId must not be null"); } if (phase == null) { throw new IllegalArgumentException("phase must not be null"); } ExecutionContext context = newContext(batchId, flowId, executionId, phase); executePhase(context); }
ExecutionTask { public void executePhase( String batchId, String flowId, String executionId, ExecutionPhase phase) throws InterruptedException, IOException { if (batchId == null) { throw new IllegalArgumentException("batchId must not be null"); } if (flowId == null) { throw new IllegalArgumentException("flowId must not be null"); } if (executionId == null) { throw new IllegalArgumentException("executionId must not be null"); } if (phase == null) { throw new IllegalArgumentException("phase must not be null"); } ExecutionContext context = newContext(batchId, flowId, executionId, phase); executePhase(context); } }
ExecutionTask { public void executePhase( String batchId, String flowId, String executionId, ExecutionPhase phase) throws InterruptedException, IOException { if (batchId == null) { throw new IllegalArgumentException("batchId must not be null"); } if (flowId == null) { throw new IllegalArgumentException("flowId must not be null"); } if (executionId == null) { throw new IllegalArgumentException("executionId must not be null"); } if (phase == null) { throw new IllegalArgumentException("phase must not be null"); } ExecutionContext context = newContext(batchId, flowId, executionId, phase); executePhase(context); } ExecutionTask(
            ExecutionMonitorProvider monitors,
            ExecutionLockProvider locks,
            JobScheduler scheduler,
            HadoopScriptHandler hadoopHandler,
            Map<String, CommandScriptHandler> commandHandlers,
            BatchScript script,
            Map<String, String> batchArguments,
            Map<String, Blob> extensions); }
ExecutionTask { public void executePhase( String batchId, String flowId, String executionId, ExecutionPhase phase) throws InterruptedException, IOException { if (batchId == null) { throw new IllegalArgumentException("batchId must not be null"); } if (flowId == null) { throw new IllegalArgumentException("flowId must not be null"); } if (executionId == null) { throw new IllegalArgumentException("executionId must not be null"); } if (phase == null) { throw new IllegalArgumentException("phase must not be null"); } ExecutionContext context = newContext(batchId, flowId, executionId, phase); executePhase(context); } ExecutionTask(
            ExecutionMonitorProvider monitors,
            ExecutionLockProvider locks,
            JobScheduler scheduler,
            HadoopScriptHandler hadoopHandler,
            Map<String, CommandScriptHandler> commandHandlers,
            BatchScript script,
            Map<String, String> batchArguments,
            Map<String, Blob> extensions); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments,
            Map<String, String> yaessArguments); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments,
            Map<String, String> yaessArguments,
            Map<String, Blob> extensions); void executeBatch(String batchId); void executeFlow(
            String batchId,
            String flowId,
            String executionId); void executePhase(
            String batchId,
            String flowId,
            String executionId,
            ExecutionPhase phase); void executePhase(ExecutionContext context); }
ExecutionTask { public void executePhase( String batchId, String flowId, String executionId, ExecutionPhase phase) throws InterruptedException, IOException { if (batchId == null) { throw new IllegalArgumentException("batchId must not be null"); } if (flowId == null) { throw new IllegalArgumentException("flowId must not be null"); } if (executionId == null) { throw new IllegalArgumentException("executionId must not be null"); } if (phase == null) { throw new IllegalArgumentException("phase must not be null"); } ExecutionContext context = newContext(batchId, flowId, executionId, phase); executePhase(context); } ExecutionTask(
            ExecutionMonitorProvider monitors,
            ExecutionLockProvider locks,
            JobScheduler scheduler,
            HadoopScriptHandler hadoopHandler,
            Map<String, CommandScriptHandler> commandHandlers,
            BatchScript script,
            Map<String, String> batchArguments,
            Map<String, Blob> extensions); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments,
            Map<String, String> yaessArguments); static ExecutionTask load(
            YaessProfile profile,
            Properties script,
            Map<String, String> batchArguments,
            Map<String, String> yaessArguments,
            Map<String, Blob> extensions); void executeBatch(String batchId); void executeFlow(
            String batchId,
            String flowId,
            String executionId); void executePhase(
            String batchId,
            String flowId,
            String executionId,
            ExecutionPhase phase); void executePhase(ExecutionContext context);  }