code: def open_stream(source, *, options=None, memory_pool=None):
      """
      Create reader for Arrow streaming format.
  
      Parameters
      ----------
      source : bytes/buffer-like, pyarrow.NativeFile, or file-like Python object
          Either an in-memory buffer, or a readable file object.
      options : pyarrow.ipc.IpcReadOptions
          Options for IPC serialization.
          If None, default values will be used.
      memory_pool : MemoryPool, default None
          If None, default memory pool is used.
  
      Returns
      -------
      reader : RecordBatchStreamReader
          A reader for the given source
      """
      return RecordBatchStreamReader(
          source, options=options, memory_pool=memory_pool
      )
  
imports: import os
  import pyarrow
  from pyarrow.lib import IpcReadOptions, IpcWriteOptions, ReadStats, WriteStats, Message, MessageReader, RecordBatchReader, _ReadPandasMixin, MetadataVersion, read_message, read_record_batch, read_schema, read_tensor, write_tensor, get_record_batch_size, get_tensor_size
  import pyarrow.lib
label_desc: Use image node_id 4 for calling a global function with example usage: open_stream(source) and returns: RecordBatchStreamReader