code: def _create_array_avro_record(schema, item_values: list):
      jvm = get_gateway().jvm
      j_record = jvm.GenericData.Record(schema._j_schema)
      item_schema = AvroSchema(
          schema._j_schema.getField("array").schema().getElementType()
      )
      j_array = jvm.java.util.ArrayList()
      for idx, item_value in enumerate(item_values):
          j_item = jvm.GenericData.Record(item_schema._j_schema)
          j_item.put("int", item_value[0])
          j_item.put("double", item_value[1])
          j_array.add(j_item)
      j_record.put("array", j_array)
      return j_record
  
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 20 for calling a global function with example usage: _create_array_avro_record(schema, item_values) and returns: j_record