Renaming IoPathFileLoader to IoPathFileOpener

ghstack-source-id: 5cc14cd
Pull Request resolved: #151

Author: NivekT

test/test_local_io.py

@@ -17,7 +17,7 @@
     FileOpener,
     IterableWrapper,
     IoPathFileLister,
-    IoPathFileLoader,
+    IoPathFileOpener,
     IoPathSaver,
     CSVParser,
     CSVDictParser,
@@ -539,7 +539,7 @@ def test_io_path_file_lister_iterdatapipe(self):
     @skipIfNoIoPath
     def test_io_path_file_loader_iterdatapipe(self):
         datapipe1 = IoPathFileLister(root=self.temp_sub_dir.name)
-        datapipe2 = IoPathFileLoader(datapipe1)
+        datapipe2 = IoPathFileOpener(datapipe1)
 
         # check contents of file match
         for _, f in datapipe2:
@@ -548,7 +548,7 @@ def test_io_path_file_loader_iterdatapipe(self):
         # Reset Test: Ensure the resulting streams are still readable after the DataPipe is reset/exhausted
         self._write_text_files()
         lister_dp = FileLister(self.temp_dir.name, "*.text")
-        iopath_file_loader_dp = IoPathFileLoader(lister_dp, mode="rb")
+        iopath_file_loader_dp = IoPathFileOpener(lister_dp, mode="rb")
 
         n_elements_before_reset = 2
         res_before_reset, res_after_reset = reset_after_n_next_calls(iopath_file_loader_dp, n_elements_before_reset)

torchdata/datapipes/iter/__init__.py

@@ -31,7 +31,7 @@
 )
 from torchdata.datapipes.iter.load.iopath import (
     IoPathFileListerIterDataPipe as IoPathFileLister,
-    IoPathFileLoaderIterDataPipe as IoPathFileLoader,
+    IoPathFileOpenerIterDataPipe as IoPathFileOpener,
     IoPathSaverIterDataPipe as IoPathSaver,
 )
 from torchdata.datapipes.iter.load.fsspec import (
@@ -103,7 +103,7 @@
     "InMemoryCacheHolder",
     "IndexAdder",
     "IoPathFileLister",
-    "IoPathFileLoader",
+    "IoPathFileOpener",
     "IoPathSaver",
     "IterDataPipe",
     "IterKeyZipper",

torchdata/datapipes/iter/load/iopath.py

@@ -80,9 +80,9 @@ def __iter__(self) -> Iterator[str]:
                     yield os.path.join(self.root, file_name)
 
 
-@functional_datapipe("load_file_by_iopath")
-class IoPathFileLoaderIterDataPipe(IterDataPipe[Tuple[str, StreamWrapper]]):
-    r""":class:`IoPathFileLoaderIterDataPipe`.
+@functional_datapipe("open_file_by_iopath")
+class IoPathFileOpenerIterDataPipe(IterDataPipe[Tuple[str, StreamWrapper]]):
+    r""":class:`IoPathFileOpenerIterDataPipe`.
 
     Iterable DataPipe to open files from input datapipe which contains pathnames or URLs,
     and yields a tuple of pathname and opened file stream.