Uses of Interface
com.onenetwork.platform.grid.GridTask
Package | Description |
---|---|
com.onenetwork.platform.grid |
Interface into One Network's Computational Grid for parallel, dependency-aware task execution.
|
com.onenetwork.platform.grid.scheduler |
Service for scheduling background jobs.
|
com.onenetwork.platform.integ.msg |
APIs for using Platform's message queuing system.
|
-
Uses of GridTask in com.onenetwork.platform.grid
Methods in com.onenetwork.platform.grid that return GridTask Modifier and Type Method Description GridTask
GridService. await(java.lang.Long taskId, long intervalInMillis, long maxAwaitInMillis)
Given a task id, waits for that task to either move to either SUCCEEDED or FAILED.GridTask
GridTaskContext. getGridTask()
GridTask
GridService. newTask(java.lang.String taskType)
Creates a new task in memory which can be inserted, or added to a jobMethods in com.onenetwork.platform.grid that return types with arguments of type GridTask Modifier and Type Method Description java.util.List<GridTask>
GridJob. getGridTaskList()
Returns the GridTasks added to this jobjava.util.Map<java.lang.Long,GridTask>
GridService. getGridTasksByIds(java.util.Collection<java.lang.Long> taskIds)
Given task ids, returns the associated GridTask objects.Methods in com.onenetwork.platform.grid with parameters of type GridTask Modifier and Type Method Description void
GridJob. addTask(GridTask task)
Add a single GridTask to this GridJob.void
GridJob. setTaskDependency(GridTask taskDependency)
Set a task that all tasks subsequently added to the job will depend on.void
GridTask. setTaskDependency(GridTask otherTask)
Task which must complete before this Task can runvoid
GridJobListener. taskFinished(GridTask task, GridJob job)
This method will be called when a task within a job is finished and the job status is updated in the DBMethod parameters in com.onenetwork.platform.grid with type arguments of type GridTask Modifier and Type Method Description void
GridJob. addTasks(java.util.Collection<GridTask> tasks)
Add multiple GridTasks to this GridJob.void
GridService. insertTasks(java.util.Collection<GridTask> tasks)
Inserts the given GridTasks into the databasevoid
GridService. queueTasks(java.lang.String queueName, java.util.Collection<GridTask> tasks)
Enqueues the given tasks into a "grid queue" with the given name.Constructors in com.onenetwork.platform.grid with parameters of type GridTask Constructor Description GridTaskContext(GridTask gridTask)
-
Uses of GridTask in com.onenetwork.platform.grid.scheduler
Methods in com.onenetwork.platform.grid.scheduler with parameters of type GridTask Modifier and Type Method Description void
TaskAwareScheduledRunnable. setGridTask(GridTask task)
-
Uses of GridTask in com.onenetwork.platform.integ.msg
Methods in com.onenetwork.platform.integ.msg with parameters of type GridTask Modifier and Type Method Description boolean
DynamicCsvChunker. isNewChunk(GridTask task, java.util.List<java.lang.String> row, DynamicChunkingContext ctx)
Return true if the current row is the start of a "new chunk" relative to the last row.default boolean
DynamicCsvChunker. useDynamicChunking(GridTask task, java.lang.Object dvceBatchUploadQueueRow, DynamicChunkingContext ctx)
Returns true if current IB needs dynamic chunking based runtime logic