Package | Description |
---|---|
org.apache.hadoop.hive.metastore.txn |
Modifier and Type | Method and Description |
---|---|
CompactionInfo |
CompactionTxnHandler.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> |
CompactionTxnHandler.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> |
CompactionTxnHandler.findReadyToClean()
Find entries in the queue that are ready to
be cleaned.
|
Modifier and Type | Method and Description |
---|---|
int |
CompactionInfo.compareTo(CompactionInfo o) |
List<String> |
CompactionTxnHandler.findColumnsWithStats(CompactionInfo ci)
Queries metastore DB directly to find columns in the table which have statistics information.
|
void |
CompactionTxnHandler.markCleaned(CompactionInfo info)
This will remove an entry from the queue after
it has been compacted.
|
void |
CompactionTxnHandler.markCompacted(CompactionInfo info)
This will mark an entry in the queue as compacted
and put it in the ready to clean state.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.