List of scheduleTask() Examples

Examples of scheduleTask()

com.linkedin.helix.Mocks.MockHelixTaskExecutor.scheduleTask()
com.sun.sgs.app.TaskManager.scheduleTask()
Schedules a task to run now. The TaskManager will call the task's {@link Task#run run} method as soon as possible after thecompletion of the task in which this method is called, according to its scheduling algorithm.
If the call to the run method throws an exception, that exception implements {@link ExceptionRetryStatus}, and its {@link ExceptionRetryStatus#shouldRetry shouldRetry} method returnstrue, then the TaskManager will make further attempts to run the task. It will continue those attempts until either an attempt succeeds or it notices an exception is thrown that is not retryable. The TaskManager is permitted to treat a non-retryable exception as a hint. In particular, a task that throws a non-retryable exception may be retried if the node running the task crashes. @param task the task to run @throws IllegalArgumentException if task does notimplement {@link Serializable} @throws TaskRejectedException if the TaskManager refusesto accept the task because of resource limitations @throws TransactionException if the operation failed because of aproblem with the current transaction
com.sun.sgs.kernel.TransactionScheduler.scheduleTask()
Schedules a task to run as soon as possible based on the specific scheduler implementation. @param task the {@code KernelRunnable} to execute @param owner the entity on who's behalf this task is run @throws TaskRejectedException if the given task is not accepted
com.sun.sgs.service.TaskService.scheduleTask()
org.apache.helix.Mocks.MockHelixTaskExecutor.scheduleTask()
org.apache.synapse.task.TaskScheduler.scheduleTask()
Schedule a Task @param taskDescription TaskDescription , an information about Task @param resources Any initial resources for task @param jobClass Quartz job class
org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()
org.fenrir.yggdrasil.core.service.ITaskLauncherService.scheduleTask()

Examples of org.apache.synapse.task.TaskScheduler.scheduleTask()

                TaskSchedulerFactory.getTaskScheduler(TASK_ID);
        if (!taskScheduler.isInitialized()) {
            Properties properties = new Properties();
            taskScheduler.init(properties);
        }        
        taskScheduler.scheduleTask(taskDescription, resources, KeepAliveJob.class);
    }
}

View Full Code Here

Examples of org.apache.synapse.task.TaskScheduler.scheduleTask()

        TaskScheduler taskScheduler = TaskSchedulerFactory.getTaskScheduler(THROTTLING_TASK_ID);
        if (!taskScheduler.isInitialized()) {
            Properties properties = new Properties();
            taskScheduler.init(properties);
        }
        taskScheduler.scheduleTask(taskDescription, resources, ThrottlingJob.class);
    }


    /**
     * get all the tenants
     * @return Tenant[]

View Full Code Here

Examples of org.apache.synapse.task.TaskScheduler.scheduleTask()

            TaskScheduler taskScheduler = TaskSchedulerFactory.getTaskScheduler(THROTTLING_TASK_ID);
            if (!taskScheduler.isInitialized()) {
                Properties properties = new Properties();
                taskScheduler.init(properties);
            }
            taskScheduler.scheduleTask(taskDescription, resources, ThrottlingJob.class);
        }
    }


    /**
     * get all the tenants

View Full Code Here

Examples of org.apache.synapse.task.TaskScheduler.scheduleTask()

            int interval = AutoscalerTaskDSHolder.getInstance().getLoadBalancerConfig().getAutoscalerTaskInterval();
            taskDescription.setInterval(interval);
            taskDescription.setStartTime(new Date(System.currentTimeMillis() + (interval*2)));


            TaskSchedulingManager scheduler = new TaskSchedulingManager();
            scheduler.scheduleTask(taskDescription, dataMap, configurationContext);




        } else {


            log.info("Autoscaling is disabled.");

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

    DAGEventSchedulerUpdate event = new DAGEventSchedulerUpdate(
        DAGEventSchedulerUpdate.UpdateType.TA_SCHEDULE, mockAttempt);    
    
    DAGScheduler scheduler = new DAGSchedulerNaturalOrder(mockDag,
        mockEventHandler);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 2);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 4);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 6);

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

    
    DAGScheduler scheduler = new DAGSchedulerNaturalOrder(mockDag,
        mockEventHandler);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 2);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 4);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 6);
    
    when(mockAttempt.getIsRescheduled()).thenReturn(true);

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

        mockEventHandler);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 2);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 4);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 6);
    
    when(mockAttempt.getIsRescheduled()).thenReturn(true);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 5);

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 4);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 6);
    
    when(mockAttempt.getIsRescheduled()).thenReturn(true);
    scheduler.scheduleTask(event);
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 5);
  }
  
  @Ignore
  @Test(timeout=10000)

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

    when(mockEvent3.getAttempt()).thenReturn(mockAttempt3);
    DAGScheduler scheduler = new DAGSchedulerMRR(mockDag, mockEventHandler,
        mockTaskScheduler, 0.5f);
    
    // M starts. M completes. R1 starts. R1 completes. R2 starts. R2 completes
    scheduler.scheduleTask(mockEvent1); // M starts
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 3);
    scheduler.scheduleTask(mockEvent1); // M runs another
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 3);
    scheduler.vertexCompleted(mockVertex1); // M completes
    scheduler.scheduleTask(mockEvent2); // R1 starts

View Full Code Here

Examples of org.apache.tez.dag.app.dag.DAGScheduler.scheduleTask()

        mockTaskScheduler, 0.5f);
    
    // M starts. M completes. R1 starts. R1 completes. R2 starts. R2 completes
    scheduler.scheduleTask(mockEvent1); // M starts
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 3);
    scheduler.scheduleTask(mockEvent1); // M runs another
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 3);
    scheduler.vertexCompleted(mockVertex1); // M completes
    scheduler.scheduleTask(mockEvent2); // R1 starts
    Assert.assertTrue(mockEventHandler.event.getPriority().getPriority() == 6);
    scheduler.scheduleTask(mockEvent2); // R1 runs another

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.