class_docstr: Serializes Arrow record batches as a stream.
class_docstr_tok: ["Serializes","Arrow","record","batches","as","a","stream","."]
code: def load_stream(self, stream):
      import pyarrow as pa
  
      reader = pa.ipc.open_stream(stream)
      for batch in reader:
          yield batch
  
imports: from pyspark.errors import PySparkRuntimeError, PySparkTypeError, PySparkValueError
  from pyspark.loose_version import LooseVersion
  from pyspark.serializers import Serializer, read_int, write_int, UTF8Deserializer, CPickleSerializer
  from pyspark.sql.pandas.types import from_arrow_type, to_arrow_type, _create_converter_from_pandas, _create_converter_to_pandas
  from pyspark.sql.types import DataType, StringType, StructType, BinaryType, StructField, LongType, IntegerType
label_desc: Use image node_id 2 for calling the ArrowStreamSerializer obj's underlying member method code with example usage: obj.load_stream(stream) without return types