Package org.apache.flink.connector.file.table

Class RowPartitionComputer

java.lang.Object

org.apache.flink.connector.file.table.RowPartitionComputer

All Implemented Interfaces:

Serializable, PartitionComputer<org.apache.flink.types.Row>

@Internal
public class RowPartitionComputer
extends Object
implements PartitionComputer<org.apache.flink.types.Row>

PartitionComputer for Row.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected String	defaultPartValue
protected String[]	partitionColumns
protected int[]	partitionIndexes

Constructor Summary

Constructors

Constructor	Description
RowPartitionComputer(String defaultPartValue, String[] columnNames, String[] partitionColumns)

Method Summary

Modifier and Type	Method	Description
LinkedHashMap<String,String>	generatePartValues(org.apache.flink.types.Row in)	Compute partition values from record.
org.apache.flink.types.Row	projectColumnsToWrite(org.apache.flink.types.Row in)	Project non-partition columns for output writer.
static Object	restorePartValueFromType(String valStr, org.apache.flink.table.types.DataType type)
static Object	restorePartValueFromType(String valStr, org.apache.flink.table.types.logical.LogicalType type)	Restore partition value from string and type.

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

partitionIndexes

protected final int[] partitionIndexes

Constructor Detail

RowPartitionComputer

public RowPartitionComputer(String defaultPartValue,
                            String[] columnNames,
                            String[] partitionColumns)

Method Detail

generatePartValues

public LinkedHashMap<String,String> generatePartValues(org.apache.flink.types.Row in)
                                                      throws Exception

Description copied from interface: PartitionComputer

Compute partition values from record.

Specified by:

generatePartValues in interface PartitionComputer<org.apache.flink.types.Row>

Parameters:

in - input record.

Returns:

partition values.

Throws:

Exception

projectColumnsToWrite

public org.apache.flink.types.Row projectColumnsToWrite(org.apache.flink.types.Row in)

Description copied from interface: PartitionComputer

Project non-partition columns for output writer.

Specified by:

projectColumnsToWrite in interface PartitionComputer<org.apache.flink.types.Row>

Parameters:

in - input record.

Returns:

projected record.

restorePartValueFromType

public static Object restorePartValueFromType(String valStr,
                                              org.apache.flink.table.types.DataType type)

restorePartValueFromType

public static Object restorePartValueFromType(String valStr,
                                              org.apache.flink.table.types.logical.LogicalType type)

Restore partition value from string and type. This method is the opposite of method generatePartValues(org.apache.flink.types.Row).

Parameters:

valStr - string partition value.

type - type of partition field.

Returns:

partition value.