code: def _check_csv_primitive_column_results(test, results):
      row = results[0]
      test.assertEqual(row["tinyint"], 127)
      test.assertEqual(row["smallint"], -32767)
      test.assertEqual(row["int"], 2147483647)
      test.assertEqual(row["bigint"], -9223372036854775808)
      test.assertAlmostEqual(row["float"], 3e38, delta=1e31)
      test.assertAlmostEqual(row["double"], 2e-308, delta=2e-301)
      test.assertAlmostEqual(row["decimal"], 2)
      test.assertEqual(row["boolean"], True)
      test.assertEqual(row["string"], "string")
  
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 2 for calling a global function with example usage: _check_csv_primitive_column_results(test, results) without return types