code: def _create_avro_file(self, schema: AvroSchema, records: list):
      jvm = get_gateway().jvm
      j_file = jvm.java.io.File(self.avro_file_name)
      j_datum_writer = (
          jvm.org.apache.flink.avro.shaded.org.apache.avro.generic.GenericDatumWriter()
      )
      j_file_writer = jvm.org.apache.flink.avro.shaded.org.apache.avro.file.DataFileWriter(
          j_datum_writer
      )
      j_file_writer.create(schema._j_schema, j_file)
      for r in records:
          j_file_writer.append(r)
      j_file_writer.close()
  
imports: import glob
  import os
  import tempfile
  from typing import Tuple, List
  from avro.datafile import DataFileReader
  from avro.io import DatumReader
  from py4j.java_gateway import JavaObject, java_import
  from pyflink.datastream import MapFunction
  from pyflink.datastream.connectors.file_system import FileSink
  from pyflink.datastream.formats.avro import AvroSchema, GenericRecordAvroTypeInfo, AvroBulkWriters, AvroInputFormat
  from pyflink.datastream.tests.test_util import DataStreamTestSinkFunction
  from pyflink.java_gateway import get_gateway
  from pyflink.testing.test_case_utils import PyFlinkUTTestCase
label_desc: Use image node_id 8 for calling the FileSourceAvroInputFormatTests obj's underlying member method code with example usage: obj._create_avro_file(schema, records) without return types