org.apache.paimon.utils

Class PartitionPathUtils

java.lang.Object

org.apache.paimon.utils.PartitionPathUtils

public class PartitionPathUtils
extends Object

Utils for file system.

Constructor Summary

Constructors

Constructor and Description
PartitionPathUtils()

Method Summary

Modifier and Type	Method and Description
static LinkedHashMap<String,String>	extractPartitionSpecFromPath(Path currPath) Make partition spec from path.
static List<String>	generateHierarchicalPartitionPaths(LinkedHashMap<String,String> partitionSpec) Generate all hierarchical paths from partition spec.
static String	generatePartitionPath(LinkedHashMap<String,String> partitionSpec) Make partition path from partition spec.
static String	generatePartitionPath(Map<String,String> partitionSpec, RowType partitionType)
static List<String>	generatePartitionPaths(List<Map<String,String>> partitions, RowType partitionType)
static String	unescapePathName(String path)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionPathUtils

public PartitionPathUtils()

Method Detail

generatePartitionPath

public static String generatePartitionPath(LinkedHashMap<String,String> partitionSpec)

Make partition path from partition spec.

Parameters:

partitionSpec - The partition spec.

Returns:

An escaped, valid partition name.

generatePartitionPaths

public static List<String> generatePartitionPaths(List<Map<String,String>> partitions,
                                                  RowType partitionType)

generatePartitionPath

public static String generatePartitionPath(Map<String,String> partitionSpec,
                                           RowType partitionType)

generateHierarchicalPartitionPaths

public static List<String> generateHierarchicalPartitionPaths(LinkedHashMap<String,String> partitionSpec)

Generate all hierarchical paths from partition spec.

For example, if the partition spec is (pt1: '0601', pt2: '12', pt3: '30'), this method will return a list (start from index 0):

• pt1=0601
• pt1=0601/pt2=12
• pt1=0601/pt2=12/pt3=30

unescapePathName

public static String unescapePathName(String path)

extractPartitionSpecFromPath

public static LinkedHashMap<String,String> extractPartitionSpecFromPath(Path currPath)

Make partition spec from path.

Parameters:

currPath - partition file path.

Returns:

Sequential partition specs.