Class PbSchemaValidationUtils


  • public class PbSchemaValidationUtils
    extends Object
    Validation class to verify protobuf definition and flink schema.
    • Constructor Detail

      • PbSchemaValidationUtils

        public PbSchemaValidationUtils()
    • Method Detail

      • validate

        public static void validate​(com.google.protobuf.Descriptors.Descriptor descriptor,
                                    org.apache.flink.table.types.logical.RowType rowType)