Package org.apache.polaris.service.task

Class ManifestFileCleanupTaskHandler

java.lang.Object

org.apache.polaris.service.task.FileCleanupTaskHandler

org.apache.polaris.service.task.ManifestFileCleanupTaskHandler

All Implemented Interfaces:

TaskHandler

public class ManifestFileCleanupTaskHandler
extends FileCleanupTaskHandler

ManifestFileCleanupTaskHandler responsible for deleting all the files in a manifest and the manifest itself. Since data files may be present in multiple manifests across different snapshots, we assume a data file that doesn't exist is missing because it was already deleted by another task.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ManifestFileCleanupTaskHandler.ManifestCleanupTask	Serialized Task data sent from the TableCleanupTaskHandler

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
ManifestFileCleanupTaskHandler(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

ManifestFileCleanupTaskHandler

public ManifestFileCleanupTaskHandler(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