@Internal public class PartitionTempFileManager extends Object
Temporary file directory contains the following directory parts: 1.temporary base path directory. 2.task id directory. 3.directories to specify partitioning. 4.data files. eg: /tmp/task-0/p0=1/p1=2/fileName.
Modifier and Type | Method and Description |
---|---|
Path |
createPartitionDir(String... partitions)
Generate a new partition directory with partitions.
|
static List<Path> |
listTaskTemporaryPaths(FileSystem fs,
Path basePath)
Returns task temporary paths in this checkpoint.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.