class_docstr: Provides a FileInputFormat for Avro records.
  
  Example:
  ::
  
      >>> env = StreamExecutionEnvironment.get_execution_environment()
      >>> schema = AvroSchema.parse_string(JSON_SCHEMA)
      >>> ds = env.create_input(AvroInputFormat(FILE_PATH, schema))
  
  .. versionadded:: 1.16.0
class_docstr_tok: ["Provides","a","FileInputFormat","for","Avro","records",".","Example",":",":",":",">",">",">","env","=","StreamExecutionEnvironment.get_execution_environment","(",")",">",">",">","schema","=","AvroSchema.parse_string","(","JSON_SCHEMA",")",">",">",">","ds","=","env.create_input","(","AvroInputFormat","(","FILE_PATH",",","schema",")",")","..","versionadded",":",":","1.16.0"]
code: def get_produced_type(self) -> GenericRecordAvroTypeInfo:
      return self._type_info
  
imports: from py4j.java_gateway import get_java_class, JavaObject, java_import
  from pyflink.common.io import InputFormat
  from pyflink.common.serialization import BulkWriterFactory, SerializationSchema, DeserializationSchema
  from pyflink.common.typeinfo import TypeInformation
  from pyflink.datastream.utils import ResultTypeQueryable
  from pyflink.java_gateway import get_gateway
  from pyflink.util.java_utils import get_field_value, load_java_class
label_desc: Use image node_id 2 for calling the AvroInputFormat obj's underlying member method code with example usage: obj.get_produced_type() and returns: self