code: def _ds_eq_streaming(ds_expected, ds_actual) -> bool:
      # Casting the strings to bytes for comparing string features
      def _str2bytes(d):
          for k, v in d.items():
              if "string" in k:
                  if isinstance(v, list):
                      d[k] = [vv.encode() for vv in v]
                  elif isinstance(v, str):
                      d[k] = v.encode()
          return d
  
      ds_expected = ds_expected.map(_str2bytes)
      assert ds_expected.take() == ds_actual.take()
  
imports: import json
  import os
  from typing import TYPE_CHECKING
  import numpy
  import pytest
  from pandas.api.types import is_float_dtype, is_int64_dtype, is_object_dtype
  import ray
  from ray.tests.conftest import *
label_desc: Use image node_id 6 for calling a global function with example usage: _ds_eq_streaming(ds_expected, ds_actual) and returns: d