Package org.apache.polaris.service.task

Class BatchFileCleanupTaskHandler

java.lang.Object

org.apache.polaris.service.task.FileCleanupTaskHandler

org.apache.polaris.service.task.BatchFileCleanupTaskHandler

All Implemented Interfaces:

TaskHandler

public class BatchFileCleanupTaskHandler
extends FileCleanupTaskHandler

BatchFileCleanupTaskHandler responsible for batch file cleanup by processing multiple file deletions in a single task handler. Valid files are deleted asynchronously with retries for transient errors, while missing files are logged and skipped.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	BatchFileCleanupTaskHandler.BatchFileCleanupTask
static enum	BatchFileCleanupTaskHandler.BatchFileType

Field Summary

Fields inherited from class org.apache.polaris.service.task.FileCleanupTaskHandler

executorService, FILE_DELETION_RETRY_MILLIS, fileIOSupplier, MAX_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
BatchFileCleanupTaskHandler(TaskFileIOSupplier fileIOSupplier, ExecutorService executorService)

Method Summary

Modifier and Type	Method	Description
boolean	canHandleTask(org.apache.polaris.core.entity.TaskEntity task)
void	handleTask(org.apache.polaris.core.entity.TaskEntity task, org.apache.polaris.core.context.CallContext callContext)	Handles the provided task.

Methods inherited from class org.apache.polaris.service.task.FileCleanupTaskHandler

tryDelete, tryDelete

Methods inherited from class java.lang.Object

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

Constructor Details

BatchFileCleanupTaskHandler

public BatchFileCleanupTaskHandler(TaskFileIOSupplier fileIOSupplier,
 ExecutorService executorService)

Method Details

canHandleTask

public boolean canHandleTask(org.apache.polaris.core.entity.TaskEntity task)

Specified by:

canHandleTask in interface TaskHandler

Specified by:

canHandleTask in class FileCleanupTaskHandler

handleTask

public void handleTask(org.apache.polaris.core.entity.TaskEntity task,
 org.apache.polaris.core.context.CallContext callContext)

Description copied from class: FileCleanupTaskHandler

Handles the provided task. A normal return indicates success and the task entity will be dropped; throwing indicates failure and triggers the task retry path.

Specified by:

handleTask in interface TaskHandler

Specified by:

handleTask in class FileCleanupTaskHandler