Package | Description |
---|---|
org.apache.hadoop.hive.ql.io |
Modifier and Type | Method and Description |
---|---|
static AcidUtils.ParsedDelta |
AcidUtils.parsedDelta(org.apache.hadoop.fs.Path deltaDir) |
Modifier and Type | Method and Description |
---|---|
List<AcidUtils.ParsedDelta> |
AcidUtils.Directory.getCurrentDirectories()
Get the list of base and delta directories that are valid and not
obsolete.
|
Modifier and Type | Method and Description |
---|---|
int |
AcidUtils.ParsedDelta.compareTo(AcidUtils.ParsedDelta parsedDelta)
Compactions (Major/Minor) merge deltas/bases but delete of old files
happens in a different process; thus it's possible to have bases/deltas with
overlapping txnId boundaries.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.fs.Path[] |
AcidUtils.getPaths(List<AcidUtils.ParsedDelta> deltas)
Convert a list of deltas to a list of delta directories.
|
static List<AcidInputFormat.DeltaMetaData> |
AcidUtils.serializeDeltas(List<AcidUtils.ParsedDelta> deltas)
Convert the list of deltas into an equivalent list of begin/end
transaction id pairs.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.