Package | Description |
---|---|
org.apache.hadoop.hive.metastore.txn |
Modifier and Type | Method and Description |
---|---|
CompactionInfo |
TxnStore.findNextToCompact(String workerId)
This will grab the next compaction request off of
the queue, and assign it to the worker.
|
Modifier and Type | Method and Description |
---|---|
Set<CompactionInfo> |
TxnStore.findPotentialCompactions(int maxAborted)
This will look through the completed_txn_components table and look for partitions or tables
that may be ready for compaction.
|
List<CompactionInfo> |
TxnStore.findReadyToClean()
Find entries in the queue that are ready to
be cleaned.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TxnStore.checkFailedCompactions(CompactionInfo ci)
Determine if there are enough consecutive failures compacting a table or partition that no
new automatic compactions should be scheduled.
|
int |
CompactionInfo.compareTo(CompactionInfo o) |
List<String> |
TxnStore.findColumnsWithStats(CompactionInfo ci)
Queries metastore DB directly to find columns in the table which have statistics information.
|
void |
TxnStore.markCleaned(CompactionInfo info)
This will remove an entry from the queue after
it has been compacted.
|
void |
TxnStore.markCompacted(CompactionInfo info)
This will mark an entry in the queue as compacted
and put it in the ready to clean state.
|
void |
TxnStore.markFailed(CompactionInfo info)
Mark a compaction entry as failed.
|
void |
TxnStore.setCompactionHighestWriteId(CompactionInfo ci,
long highestWriteId)
Record the highest write id that the
ci compaction job will pay attention to. |
Copyright © 2022 The Apache Software Foundation. All rights reserved.