pyflink.datastream.formats.avro.GenericRecordAvroTypeInfo#
- class GenericRecordAvroTypeInfo(schema: pyflink.datastream.formats.avro.AvroSchema)[source]#
A
TypeInformation
of Avro’s GenericRecord, including the schema. This is a wrapper of Java org.apache.flink.formats.avro.typeutils.GenericRecordAvroTypeInfo.Note that this type cannot be used as the type_info of data in
StreamExecutionEnvironment.from_collection()
.Methods
from_internal_type
(obj)Converts an internal object into a native Python object.
get_java_type_info
()need_conversion
()Does this type need to conversion between Python object and internal Wrapper object.
to_internal_type
(obj)Converts a Python object into an internal object.