Interface Summary Interface Description ClusterExecutionHelperHelps with the intra-cluster remote code execution. ClusterExecutionHelper.ClientCode LightweightIdentifierGenerator LightweightTaskHandlerHandler for a lightweight task. RunningLightweightTaskRunning lightweight asynchronous task. RunningTaskA task that is directly used to execute the handler code. RunningTaskStatisticsCollector"Statistics collection" aspect of a running task. TaskTask instance - a logical unit of work. TaskDeletionListener TaskHandler TaskListenerNotifies external observers about task-related events. TaskManagerTask Manager Interface. TaskManagerAware TaskPartitionsDefinitionConfiguration for PartitioningTaskHandler: describes how to create subtasks (partitions) for the given master task. TaskPartitionsDefinition.TaskPartitionDefinitionDescription of a given partition. Tracer WorkBucketAwareTaskHandlerTask handler that supports bucketed tasks.
Class Summary Class Description ClusterExecutionOptionsOptions related to remote code execution in the cluster. LightweightIdentifierLightweight identifier is a "reasonable unique" identifier that is very cheap to create. StateReporterTODO better name (ProgressReporter ? StatisticsReporter ? ...) Used to report state, progress and performance statistics to upper layers. StaticTaskPartitionsDefinitionTask partitions definition based on statically configured values. StatisticsCollectionStrategyDescribes how task statistics (including progress and structured progress) are to be collected. TaskCategory Deprecated. TaskConstants TaskDebugUtil TaskManagerUtil TaskRunResultSingle-purpose class to return task run results. TaskUtilUtility methods related to the
Enum Summary Enum Description TaskPersistenceStatusTask persistence status. TaskRunResult.TaskRunResultStatus UseThreadInterrupt
Exception Summary Exception Description ExitHandlerExceptionUsed to signal that we have to exit handler processing with a given run result. ExitWorkBucketHandlerExceptionUsed to signal that we have to exit handler processing with a given run result. TaskExceptionException that carries supplementary information on how it should be treated (with the respect to operation result and task run result status). TaskManagerConfigurationExceptionSignals a TaskManagerExceptionCreated with IntelliJ IDEA. TaskManagerInitializationException