flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
/**
	 * Converts the extracted AvroTypeInfo into a RowTypeInfo nested structure with deterministic field order.
	 * Replaces generic Utf8 with basic String type information.
	 */
Converts the extracted AvroTypeInfo into a RowTypeInfo nested structure with deterministic field order.
Replaces generic Utf8 with basic String type information.
Converts the extracted AvroTypeInfo into a RowTypeInfo nested structure with deterministic field order . Replaces generic Utf8 with basic String type information .
@SuppressWarnings("unchecked")
	private static <T extends SpecificRecordBase> TypeInformation<Row> convertToRowTypeInformation(Class<T> avroClass) {
		final AvroTypeInfo<T> avroTypeInfo = new AvroTypeInfo<>(avroClass);
		final Schema schema = SpecificData.get().getSchema(avroClass);
		return (TypeInformation<Row>) convertToTypeInformation(avroTypeInfo, schema);
	}
@ SuppressWarnings ( "unchecked" ) private static < T extends SpecificRecordBase > TypeInformation < Row > convertToRowTypeInformation ( Class < T > avroClass ) { final AvroTypeInfo < T > avroTypeInfo = new AvroTypeInfo < > ( avroClass ) ; final Schema schema = SpecificData . get ( ) . getSchema ( avroClass ) ; return ( TypeInformation < Row > ) convertToTypeInformation ( avroTypeInfo , schema ) ; }
Converts the extracted AvroTypeInfo into a RowTypeInfo nested structure with deterministic field order.
Converts the extracted AvroTypeInfo into a RowTypeInfo nested structure with deterministic field order .
// determine schema to retrieve deterministic field order