org.apache.paimon.utils

Class InternalRowPartitionComputer

java.lang.Object

org.apache.paimon.utils.InternalRowPartitionComputer

public class InternalRowPartitionComputer
extends Object

PartitionComputer for InternalRow.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	defaultPartValue
protected String[]	partitionColumns
protected InternalRow.FieldGetter[]	partitionFieldGetters

Constructor Summary

Constructors

Constructor and Description
InternalRowPartitionComputer(String defaultPartValue, RowType rowType, String[] partitionColumns)

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	convertSpecToInternal(Map<String,String> spec, RowType partType, String defaultPartValue)
LinkedHashMap<String,String>	generatePartValues(InternalRow in)
static String	partToSimpleString(RowType partitionType, BinaryRow partition, String delimiter, int maxLength)

Methods inherited from class java.lang.Object

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

Field Detail

defaultPartValue

protected final String defaultPartValue

partitionColumns

protected final String[] partitionColumns

partitionFieldGetters

protected final InternalRow.FieldGetter[] partitionFieldGetters

Constructor Detail

InternalRowPartitionComputer

public InternalRowPartitionComputer(String defaultPartValue,
                                    RowType rowType,
                                    String[] partitionColumns)

Method Detail

generatePartValues

public LinkedHashMap<String,String> generatePartValues(InternalRow in)

convertSpecToInternal

public static Map<String,Object> convertSpecToInternal(Map<String,String> spec,
                                                       RowType partType,
                                                       String defaultPartValue)

partToSimpleString

public static String partToSimpleString(RowType partitionType,
                                        BinaryRow partition,
                                        String delimiter,
                                        int maxLength)