SqlTypeParser¶

Demo¶

import io.confluent.ksql.schema.ksql.SqlTypeParser
val typeParser = SqlTypeParser.create(TypeRegistry.EMPTY)

Creating Instance¶

SqlTypeParser takes the following to be created:

• TypeRegistry

SqlTypeParser is created using create factory.

Creating SqlTypeParser¶

SqlTypeParser create(
  TypeRegistry typeRegistry)

create creates a SqlTypeParser with the given TypeRegistry.

create is used when:

• UserFunctionLoader is created
• AstBuilder.Visitor is created
• SchemaParser is requested to parse a schema
• SqlTypeDeserializer is requested to deserialize
• KsqlTargetUtil is requested to createSchema

getType¶

Type getType(
  SqlBaseParser.TypeContext type)

getType getSqlType and creates a Type.

getType is used when:

• AstBuilder.Visitor is requested to visitAlterOption, visitCast, visitTableElement, visitRegisterType
• SchemaParser is requested to parse a schema
• SqlTypeParser is requested to parse a schema

getSqlType¶

SqlType getSqlType(
  SqlBaseParser.TypeContext type)

getSqlType...FIXME