public abstract class TaskHandler extends Object
Modifier and Type | Field and Description |
---|---|
protected HiveConf |
conf |
protected long |
defaultRetention |
protected FSRemover |
fsRemover |
protected MetadataCache |
metadataCache |
protected boolean |
metricsEnabled |
protected TxnStore |
txnHandler |
Modifier and Type | Method and Description |
---|---|
protected boolean |
cleanAndVerifyObsoleteDirectories(CompactionInfo info,
String location,
ValidReaderWriteIdList validWriteIdList,
Table table) |
abstract List<Runnable> |
getTasks() |
protected ValidReaderWriteIdList |
getValidCleanerWriteIdList(CompactionInfo info,
ValidTxnList validTxnList) |
protected void |
handleCleanerAttemptFailure(CompactionInfo info,
String errorMessage) |
protected Partition |
resolvePartition(String dbName,
String tableName,
String partName) |
protected Table |
resolveTable(String dbName,
String tableName) |
protected final TxnStore txnHandler
protected final HiveConf conf
protected final boolean metricsEnabled
protected final MetadataCache metadataCache
protected final FSRemover fsRemover
protected final long defaultRetention
public abstract List<Runnable> getTasks() throws MetaException
MetaException
protected Table resolveTable(String dbName, String tableName) throws MetaException
MetaException
protected Partition resolvePartition(String dbName, String tableName, String partName) throws MetaException
MetaException
protected ValidReaderWriteIdList getValidCleanerWriteIdList(CompactionInfo info, ValidTxnList validTxnList) throws NoSuchTxnException, MetaException
NoSuchTxnException
MetaException
protected boolean cleanAndVerifyObsoleteDirectories(CompactionInfo info, String location, ValidReaderWriteIdList validWriteIdList, Table table) throws MetaException, IOException
MetaException
IOException
protected void handleCleanerAttemptFailure(CompactionInfo info, String errorMessage) throws MetaException
MetaException
Copyright © 2023 The Apache Software Foundation. All rights reserved.