code: def _install():
      from pyflink import common
  
      # json
      from pyflink.datastream.formats.json import (
          JsonRowDeserializationSchema,
      )
      from pyflink.datastream.formats.json import (
          JsonRowSerializationSchema,
      )
  
      setattr(
          common,
          "JsonRowDeserializationSchema",
          JsonRowDeserializationSchema,
      )
      setattr(
          common,
          "JsonRowSerializationSchema",
          JsonRowSerializationSchema,
      )
  
      # csv
      from pyflink.datastream.formats.csv import (
          CsvRowDeserializationSchema,
      )
      from pyflink.datastream.formats.csv import (
          CsvRowSerializationSchema,
      )
  
      setattr(
          common,
          "CsvRowDeserializationSchema",
          CsvRowDeserializationSchema,
      )
      setattr(
          common, "CsvRowSerializationSchema", CsvRowSerializationSchema
      )
  
      # avro
      from pyflink.datastream.formats.avro import (
          AvroRowDeserializationSchema,
      )
      from pyflink.datastream.formats.avro import (
          AvroRowSerializationSchema,
      )
  
      setattr(
          common,
          "AvroRowDeserializationSchema",
          AvroRowDeserializationSchema,
      )
      setattr(
          common,
          "AvroRowSerializationSchema",
          AvroRowSerializationSchema,
      )
  
file_path: flink/flink-python/pyflink/common/__init__.py
imports: from pyflink.common.completable_future import CompletableFuture
  from pyflink.common.config_options import ConfigOption, ConfigOptions
  from pyflink.common.configuration import Configuration
  from pyflink.common.execution_config import ExecutionConfig
  from pyflink.common.execution_mode import ExecutionMode
  from pyflink.common.input_dependency_constraint import InputDependencyConstraint
  from pyflink.common.job_client import JobClient
  from pyflink.common.job_execution_result import JobExecutionResult
  from pyflink.common.job_id import JobID
  from pyflink.common.job_status import JobStatus
  from pyflink.common.restart_strategy import RestartStrategies, RestartStrategyConfiguration
  from pyflink.common.serialization import SerializationSchema, DeserializationSchema, SimpleStringSchema, Encoder
  from pyflink.common.serializer import TypeSerializer
  from pyflink.common.typeinfo import Types, TypeInformation
  from pyflink.common.types import Row, RowKind
  from pyflink.common.time import Duration, Instant, Time
  from pyflink.common.watermark_strategy import WatermarkStrategy, AssignerWithPeriodicWatermarksWrapper
label_desc: Use image node_id 1 for calling a global function with example usage: _install() without return types