Filesystem: Add reader for ORC format

docs/changelog.md

@@ -8,6 +8,7 @@
 - Filesystem: Fail ingestion when a concrete source path matches no file while
   keeping unmatched glob selections valid. Thanks, @hampsterx.
 - Filesystem: Added rsync source connector. Thanks, @oferchen.
+- Filesystem: Added reader for ORC format
 
 ## 2026/07/27 v0.8.0
 

src/dlt_filesystem/source/adapter.py

@@ -34,6 +34,7 @@
     read_jsonl,
     read_msgpack,
     read_ods,
+    read_orc,
     read_parquet,
     read_xml,
     read_yaml,
@@ -78,6 +79,8 @@ def readers(
         filesystem_resource
         | dlt.transformer(name="read_msgpack", max_table_nesting=0)(read_msgpack),
         filesystem_resource
+        | dlt.transformer(name="read_orc", max_table_nesting=0)(read_orc),
+        filesystem_resource
         | dlt.transformer(name="read_cbor", max_table_nesting=0)(read_cbor),
         filesystem_resource
         | dlt.transformer(name="read_xml", max_table_nesting=0)(read_xml),

src/dlt_filesystem/source/format/readers.py

@@ -52,6 +52,24 @@ def _polars_csv_symbols() -> Dict[str, Any]:
     }
 
 
+def _pandas_orc_symbols() -> Dict[str, Any]:
+    """Symbols needed to resolve `pandas.read_orc`'s type hints for casting reader hints."""
+
+    import fsspec
+    import pyarrow
+    from pandas import DataFrame
+    from pandas._typing import DtypeBackend, FilePath, ReadBuffer
+
+    return {
+        "DataFrame": DataFrame,
+        "DtypeBackend": DtypeBackend,
+        "FilePath": FilePath,
+        "fsspec": fsspec,
+        "pyarrow": pyarrow,
+        "ReadBuffer": ReadBuffer,
+    }
+
+
 def _polars_spreadsheet_symbols() -> Dict[str, Any]:
     """Symbols needed to cast reader hint values for `polars.read_excel` and `polars.read_ods`."""
     from typing import Sequence
@@ -400,6 +418,25 @@ def read_spreadsheet(
             yield dlt.mark.with_table_name(rows, sheet_name)
 
 
+def read_orc(
+    items: Iterator[FileItemDict],
+    **kwargs,
+) -> Iterator[TDataItems]:
+    """Reader for ORC files."""
+
+    import pandas as pd
+
+    reader = pd.read_orc
+
+    kwargs = cast_kwargs_to_signature(reader, kwargs, symbols=_pandas_orc_symbols())
+    kwargs.setdefault("dtype_backend", "pyarrow")
+
+    for file_obj in items:
+        with file_obj.open() as f:
+            df = reader(f, **kwargs)
+            yield df.to_dict(orient="records")
+
+
 def read_jsonl(
     items: Iterator[FileItemDict], chunksize: int = 1000
 ) -> Iterator[TDataItems]:
@@ -642,6 +679,10 @@ def read_bson(self) -> DltResource:
         def read_msgpack(self) -> DltResource:
             """MessagePack reader resource."""
 
+        @copy_sig(read_orc)
+        def read_orc(self) -> DltResource:
+            """ORC reader resource (pyarrow)."""
+
         @copy_sig(read_cbor)
         def read_cbor(self) -> DltResource:
             """CBOR reader resource."""

src/dlt_filesystem/source/format/registry.py

@@ -6,6 +6,7 @@
     "csv_headless": "read_csv_headless",
     "jsonl": "read_jsonl",
     "ods": "read_ods",
+    "orc": "read_orc",
     "parquet": "read_parquet",
     # bson is read-only: the file:// destination's WRITE_FORMATS is a separate tuple.
     "bson": "read_bson",

src/dlt_filesystem/testing/writer.py

@@ -1,3 +1,9 @@
+import typing
+
+if typing.TYPE_CHECKING:
+    import pandas as pd
+
+
 def write_bson(path, docs):
     """Write BSON documents concatenated into a single file (on-disk mongodump form)."""
     import bson
@@ -27,6 +33,12 @@ def write_msgpack(path, rows, **packb_kwargs):
     return path
 
 
+def write_orc(path, df: "pd.DataFrame"):
+    """Write dataframe to ORC file."""
+    df.to_orc(path)
+    return path
+
+
 def write_xml(path, text):
     """Write raw XML ``text`` to ``path`` as UTF-8 bytes."""
     with open(path, "wb") as f:

tests/dlt_filesystem/format/test_orc.py

@@ -0,0 +1,19 @@
+import pandas as pd
+
+from dlt_filesystem.source.fsspec.local import LocalFilesystemSource
+from dlt_filesystem.testing.writer import write_orc
+
+
+def _read_via_source(path):
+    """Read a local ORC file end-to-end through the shared filesystem reader."""
+    return list(LocalFilesystemSource().dlt_source(f"file://{path}", ""))
+
+
+# --- end-to-end reader (fsspec, no Docker) ---
+
+
+def test_reads_single_top_level_object(tmp_path):
+    """A single top-level ORC map loads as one record."""
+    data = pd.DataFrame.from_records([{"id": 1, "name": "alice"}])
+    path = write_orc(tmp_path / "one.orc", data)
+    assert _read_via_source(path) == [{"id": 1, "name": "alice"}]