code: def _create_csv_use_header_schema_and_lines() -> (
      Tuple[CsvSchema, List[str]]
  ):
      schema = (
          CsvSchema.builder()
          .add_string_column("string")
          .add_number_column("number")
          .set_use_header()
          .build()
      )
      lines = [
          "h1,h2\n",
          "string,123\n",
      ]
      return schema, lines
  
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 7 for calling a global function with example usage: _create_csv_use_header_schema_and_lines() and returns: schema,  lines