org.apache.flink.table.filesystem

Class RowDataPartitionComputer

java.lang.Object

org.apache.flink.table.filesystem.RowDataPartitionComputer

All Implemented Interfaces:

Serializable, PartitionComputer<RowData>

Direct Known Subclasses:

HiveRowDataPartitionComputer

@Internal
public class RowDataPartitionComputer
extends Object
implements PartitionComputer<RowData>

PartitionComputer for RowData.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	defaultPartValue
protected RowData.FieldGetter[]	nonPartitionFieldGetters
protected String[]	partitionColumns
protected RowData.FieldGetter[]	partitionFieldGetters
protected int[]	partitionIndexes
protected LogicalType[]	partitionTypes

Constructor Summary

Constructors

Constructor and Description
RowDataPartitionComputer(String defaultPartValue, String[] columnNames, DataType[] columnTypes, String[] partitionColumns)

Method Summary

Modifier and Type	Method and Description
LinkedHashMap<String,String>	generatePartValues(RowData in) Compute partition values from record.
RowData	projectColumnsToWrite(RowData in) Project non-partition columns for output writer.

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

partitionTypes

protected final LogicalType[] partitionTypes

partitionFieldGetters

protected final RowData.FieldGetter[] partitionFieldGetters

nonPartitionFieldGetters

protected final RowData.FieldGetter[] nonPartitionFieldGetters

Constructor Detail

RowDataPartitionComputer

public RowDataPartitionComputer(String defaultPartValue,
                                String[] columnNames,
                                DataType[] columnTypes,
                                String[] partitionColumns)

Method Detail

generatePartValues

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

Description copied from interface: PartitionComputer

Compute partition values from record.

Specified by:

generatePartValues in interface PartitionComputer<RowData>

Parameters:

in - input record.

Returns:

partition values.

projectColumnsToWrite

public RowData projectColumnsToWrite(RowData in)

Description copied from interface: PartitionComputer

Project non-partition columns for output writer.

Specified by:

projectColumnsToWrite in interface PartitionComputer<RowData>

Parameters:

in - input record.

Returns:

projected record.