Package org.apache.flink.formats.protobuf.util

Class PbToRowTypeUtil

java.lang.Object

org.apache.flink.formats.protobuf.util.PbToRowTypeUtil

public class PbToRowTypeUtil
extends Object

Generate Row type information according to pb descriptors.

Constructor Summary

Constructors

Constructor	Description
PbToRowTypeUtil()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.types.logical.RowType	generateRowType(com.google.protobuf.Descriptors.Descriptor root)
static org.apache.flink.table.types.logical.RowType	generateRowType(com.google.protobuf.Descriptors.Descriptor root, boolean enumAsInt)

Methods inherited from class java.lang.Object

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

Constructor Detail

PbToRowTypeUtil

public PbToRowTypeUtil()

Method Detail

generateRowType

public static org.apache.flink.table.types.logical.RowType generateRowType(com.google.protobuf.Descriptors.Descriptor root)

generateRowType

public static org.apache.flink.table.types.logical.RowType generateRowType(com.google.protobuf.Descriptors.Descriptor root,
                                                                           boolean enumAsInt)