code: def _build_csv_job(self, schema, lines):
      with open(self.csv_file_name, "w") as f:
          for line in lines:
              f.write(line)
      source = FileSource.for_record_stream_format(
          CsvReaderFormat.for_schema(schema), self.csv_file_name
      ).build()
      ds = self.env.from_source(
          source, WatermarkStrategy.no_watermarks(), "csv-source"
      )
      ds.map(
          PassThroughMapFunction(),
          output_type=Types.PICKLED_BYTE_ARRAY(),
      ).add_sink(self.test_sink)
  
imports: import glob
  import os
  import tempfile
  from typing import Tuple, List
  from pyflink.common import WatermarkStrategy, Types
  from pyflink.datastream import MapFunction
  from pyflink.datastream.connectors.file_system import FileSource, FileSink
  from pyflink.datastream.formats.csv import CsvSchema, CsvReaderFormat, CsvBulkWriters, CsvRowSerializationSchema, CsvRowDeserializationSchema
  from pyflink.datastream.tests.test_util import DataStreamTestSinkFunction
  from pyflink.java_gateway import get_gateway
  from pyflink.table import DataTypes
  from pyflink.testing.test_case_utils import PyFlinkStreamingTestCase, PyFlinkTestCase
  from pyflink.util.java_utils import get_j_env_configuration
label_desc: Use image node_id 11 for calling the FileSourceCsvReaderFormatTests obj's underlying member method code with example usage: obj._build_csv_job(schema, lines) without return types