Package org.apache.flink.table.typeutils

Class RowTypeUtils

java.lang.Object

org.apache.flink.table.typeutils.RowTypeUtils

@Internal
public class RowTypeUtils
extends Object

Utils for deriving row types of org.apache.calcite.rel.RelNode.

Constructor Summary

Constructors

Constructor	Description
RowTypeUtils()

Method Summary

Modifier and Type	Method	Description
static String	getUniqueName(String oldName, List<String> checklist)
static List<String>	getUniqueName(List<String> oldNames, List<String> checklist)
static RowType	projectRowType(RowType rowType, int[] projection)	Returns projected RowType by given projection indexes over original RowType.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowTypeUtils

public RowTypeUtils()

Method Detail

getUniqueName

public static String getUniqueName(String oldName,
                                   List<String> checklist)

getUniqueName

public static List<String> getUniqueName(List<String> oldNames,
                                         List<String> checklist)

projectRowType

public static RowType projectRowType(@Nonnull
                                     RowType rowType,
                                     @Nonnull
                                     int[] projection)
                              throws IllegalArgumentException

Returns projected RowType by given projection indexes over original RowType. Will raise an error when projection index beyond the field count of original rowType.

Parameters:

rowType - source row type

projection - indexes array

Returns:

projected RowType

Throws:

IllegalArgumentException