code: def _install():
      from pyflink.datastream import connectors
  
      # number_seq
      from pyflink.datastream.connectors import number_seq
  
      setattr(
          connectors,
          "NumberSequenceSource",
          number_seq.NumberSequenceSource,
      )
  
      # jdbc
      from pyflink.datastream.connectors import jdbc
  
      setattr(connectors, "JdbcSink", jdbc.JdbcSink)
      setattr(
          connectors,
          "JdbcConnectionOptions",
          jdbc.JdbcConnectionOptions,
      )
      setattr(
          connectors, "JdbcExecutionOptions", jdbc.JdbcExecutionOptions
      )
  
      # kafka
      from pyflink.datastream.connectors import kafka
  
      setattr(connectors, "KafkaSource", kafka.KafkaSource)
      setattr(
          connectors, "FlinkKafkaConsumer", kafka.FlinkKafkaConsumer
      )
      setattr(
          connectors, "FlinkKafkaProducer", kafka.FlinkKafkaProducer
      )
      setattr(connectors, "Semantic", kafka.Semantic)
  
      # pulsar
      from pyflink.datastream.connectors import pulsar
  
      setattr(connectors, "PulsarSource", pulsar.PulsarSource)
      setattr(
          connectors, "PulsarSourceBuilder", pulsar.PulsarSourceBuilder
      )
      setattr(connectors, "StartCursor", pulsar.StartCursor)
      setattr(connectors, "StopCursor", pulsar.StopCursor)
  
      # rabbitmq
      from pyflink.datastream.connectors import rabbitmq
  
      setattr(connectors, "RMQSource", rabbitmq.RMQSource)
      setattr(connectors, "RMQSink", rabbitmq.RMQSink)
      setattr(
          connectors,
          "RMQConnectionConfig",
          rabbitmq.RMQConnectionConfig,
      )
  
      # filesystem
      from pyflink.datastream.connectors import file_system
  
      setattr(connectors, "BucketAssigner", file_system.BucketAssigner)
      setattr(
          connectors,
          "FileEnumeratorProvider",
          file_system.FileEnumeratorProvider,
      )
      setattr(connectors, "FileSink", file_system.FileSink)
      setattr(
          connectors,
          "FileSplitAssignerProvider",
          file_system.FileSplitAssignerProvider,
      )
      setattr(connectors, "FileSource", file_system.FileSource)
      setattr(
          connectors, "FileSourceBuilder", file_system.FileSourceBuilder
      )
      setattr(
          connectors, "OutputFileConfig", file_system.OutputFileConfig
      )
      setattr(connectors, "RollingPolicy", file_system.RollingPolicy)
      setattr(connectors, "StreamFormat", file_system.StreamFormat)
      setattr(
          connectors, "StreamingFileSink", file_system.StreamingFileSink
      )
  
label_desc: Use image node_id 1 for calling a global function with example usage: _install() without return types