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 boolean	legacyPartitionName
protected CastExecutor[]	partitionCastExecutors
protected String[]	partitionColumns
protected InternalRow.FieldGetter[]	partitionFieldGetters
protected List<DataType>	types

Constructor Summary

Constructors

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

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

partitionCastExecutors

protected final CastExecutor[] partitionCastExecutors

types

protected final List<DataType> types

legacyPartitionName

protected final boolean legacyPartitionName

Constructor Detail

InternalRowPartitionComputer

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

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)