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,
org.apache.hadoop.fs.FileSystem fs) |
static AcidUtils.ParsedDelta |
AcidUtils.parsedDelta(org.apache.hadoop.fs.Path deltaDir,
String deltaPrefix,
org.apache.hadoop.fs.FileSystem fs) |
Modifier and Type | Method and Description |
---|---|
List<AcidUtils.ParsedDelta> |
AcidUtils.DirectoryImpl.getCurrentDirectories() |
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 writeId 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
write id pairs.
|
Constructor and Description |
---|
DirectoryImpl(List<org.apache.hadoop.fs.FileStatus> abortedDirectories,
boolean isBaseInRawFormat,
List<HadoopShims.HdfsFileStatusWithId> original,
List<org.apache.hadoop.fs.FileStatus> obsolete,
List<AcidUtils.ParsedDelta> deltas,
org.apache.hadoop.fs.Path base) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.