Package org.apache.polaris.service.task

Class TaskExecutorImpl

java.lang.Object

org.apache.polaris.service.task.TaskExecutorImpl

All Implemented Interfaces:

TaskExecutor

@ApplicationScoped
public class TaskExecutorImpl
extends Object
implements TaskExecutor

Given a list of registered TaskHandlers, execute tasks asynchronously with the provided CallContext.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TaskExecutorImpl()
	TaskExecutorImpl(Executor executor, jakarta.enterprise.inject.Instance<org.apache.commons.lang3.function.TriConsumer<Long,Boolean,Throwable>> errorHandler, Clock clock, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory, TaskFileIOSupplier fileIOSupplier, RealmContextHolder realmContextHolder, PolarisEventDispatcher polarisEventDispatcher, PolarisEventMetadataFactory eventMetadataFactory, @Nullable io.opentelemetry.api.trace.Tracer tracer, PolarisPrincipalHolder polarisPrincipalHolder, org.apache.polaris.core.auth.PolarisPrincipal polarisPrincipal)

Method Summary

Modifier and Type	Method	Description
void	addTaskHandler(TaskHandler taskHandler)	Add a TaskHandler.
void	addTaskHandlerContext(long taskEntityId, org.apache.polaris.core.context.CallContext callContext)	Register a CallContext for a specific task id.
protected void	handleTask(long taskEntityId, org.apache.polaris.core.context.CallContext ctx, PolarisEventMetadata eventMetadata, int attempt)
protected void	handleTaskWithTracing(String realmId, long taskEntityId, org.apache.polaris.core.context.CallContext callContext, org.apache.polaris.core.auth.PolarisPrincipal principal, PolarisEventMetadata eventMetadata, int attempt)
void	init()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskExecutorImpl

protected TaskExecutorImpl()

TaskExecutorImpl

@Inject
public TaskExecutorImpl(@Identifier("task-executor")
 Executor executor,
 @Identifier("task-error-handler")
 jakarta.enterprise.inject.Instance<org.apache.commons.lang3.function.TriConsumer<Long,Boolean,Throwable>> errorHandler,
 Clock clock,
 org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory,
 TaskFileIOSupplier fileIOSupplier,
 RealmContextHolder realmContextHolder,
 PolarisEventDispatcher polarisEventDispatcher,
 PolarisEventMetadataFactory eventMetadataFactory,
 @Nullable io.opentelemetry.api.trace.Tracer tracer,
 PolarisPrincipalHolder polarisPrincipalHolder,
 org.apache.polaris.core.auth.PolarisPrincipal polarisPrincipal)

Method Details

init

public void init()

addTaskHandler

public void addTaskHandler(TaskHandler taskHandler)

Add a TaskHandler. TaskEntitys will be tested against the TaskHandler.canHandleTask(TaskEntity) method and will be handled by the first handler that responds true.

addTaskHandlerContext

public void addTaskHandlerContext(long taskEntityId,
 org.apache.polaris.core.context.CallContext callContext)

Register a CallContext for a specific task id. That task will be loaded and executed asynchronously with a clone of the provided CallContext.

Specified by:

addTaskHandlerContext in interface TaskExecutor

handleTask

protected void handleTask(long taskEntityId,
 org.apache.polaris.core.context.CallContext ctx,
 PolarisEventMetadata eventMetadata,
 int attempt)

handleTaskWithTracing

@ActivateRequestContext
protected void handleTaskWithTracing(String realmId,
 long taskEntityId,
 org.apache.polaris.core.context.CallContext callContext,
 org.apache.polaris.core.auth.PolarisPrincipal principal,
 PolarisEventMetadata eventMetadata,
 int attempt)