code: def _build_avro_job(self, schema, objects):
      ds = self.env.from_collection(objects)
      sink = FileSink.for_bulk_format(
          self.avro_dir_name, AvroBulkWriters.for_generic_record(schema)
      ).build()
      ds.map(
          lambda e: e, output_type=GenericRecordAvroTypeInfo(schema)
      ).sink_to(sink)
  
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 7 for calling the FileSinkAvroWritersTests obj's underlying member method code with example usage: obj._build_avro_job(schema, objects) without return types