code: def test_read_text_partitioning(ray_start_regular_shared, tmp_path):
      path = os.path.join(tmp_path, "country=us")
      os.mkdir(path)
      with open(os.path.join(path, "file.txt"), "w") as f:
          f.write("foo\nbar\nbaz")
  
      ds = ray.data.read_text(path, partitioning=Partitioning("hive"))
  
      df = ds.to_pandas()
      assert list(df.columns) == ["text", "country"]
      assert sorted(df["text"]) == ["bar", "baz", "foo"]
      assert list(df["country"]) == ["us", "us", "us"]
  
file_path: ray/python/ray/data/tests/test_text.py
imports: import os
  import pandas
  import pytest
  import ray
  from ray.data.datasource import BaseFileMetadataProvider, FastFileMetadataProvider, Partitioning, PartitionStyle, PathPartitionFilter
  from ray.data.tests.conftest import *
  from ray.data.tests.mock_http_server import *
  from ray.data.tests.test_partitioning import PathPartitionEncoder
  from ray.data.tests.util import Counter
  from ray.tests.conftest import *
label_desc: Use image node_id 2 for calling a global function with example usage: test_read_text_partitioning(ray_start_regular_shared, tmp_path) without return types