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, Clock clock, org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory, TaskFileIOSupplier fileIOSupplier, PolarisEventListener polarisEventListener, io.opentelemetry.api.trace.Tracer tracer)

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, int attempt)
protected void	handleTaskWithTracing(long taskEntityId, org.apache.polaris.core.context.CallContext callContext, 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,
 Clock clock,
 org.apache.polaris.core.persistence.MetaStoreManagerFactory metaStoreManagerFactory,
 TaskFileIOSupplier fileIOSupplier,
 PolarisEventListener polarisEventListener,
 @Nullable
 io.opentelemetry.api.trace.Tracer tracer)

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,
 int attempt)

handleTaskWithTracing

protected void handleTaskWithTracing(long taskEntityId,
 org.apache.polaris.core.context.CallContext callContext,
 int attempt)