org.apache.flink.table.planner.typeutils

Class RowTypeUtils

java.lang.Object

org.apache.flink.table.planner.typeutils.RowTypeUtils

public class RowTypeUtils
extends Object

Utils for deriving row types of RelNodes.

Constructor Summary

Constructors

Constructor and Description
RowTypeUtils()

Method Summary

Modifier and Type	Method and Description
static List<String>	getUniqueName(List<String> oldNames, List<String> checklist)
static String	getUniqueName(String oldName, 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