org.apache.flink.connectors.hive

Class HiveRowPartitionComputer

java.lang.Object

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

org.apache.flink.connectors.hive.HiveRowPartitionComputer

All Implemented Interfaces:

Serializable, PartitionComputer<Row>

public class HiveRowPartitionComputer
extends RowPartitionComputer

A RowPartitionComputer that converts Flink objects to Hive objects before computing the partition value strings.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.connector.file.table.RowPartitionComputer

defaultPartValue, partitionColumns, partitionIndexes

Method Summary

Modifier and Type	Method and Description
LinkedHashMap<String,String>	generatePartValues(Row in) Compute partition values from record.

Methods inherited from class org.apache.flink.connector.file.table.RowPartitionComputer

projectColumnsToWrite, restorePartValueFromType, restorePartValueFromType

Methods inherited from class java.lang.Object

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

Method Detail

generatePartValues

public LinkedHashMap<String,String> generatePartValues(Row in)
                                                throws Exception

Description copied from interface: PartitionComputer

Compute partition values from record.

Specified by:

generatePartValues in interface PartitionComputer<Row>

Overrides:

generatePartValues in class RowPartitionComputer

Parameters:

in - input record.

Returns:

partition values.

Throws:

Exception