.gitignore
README.md
pyproject.toml
pytest.ini
uv.lock
.devcontainer/Dockerfile
.devcontainer/devcontainer.json
.github/workflows/run-tests.yml
examples/dataset1/day1.txt
examples/dataset1/day2.txt
examples/dataset1/day3.txt
examples/dataset1/day4.txt
examples/dataset1/day6.txt
examples/dataset2/info_day1.json
examples/dataset2/info_day2.json
examples/dataset2/info_day3.json
examples/dataset2/info_day4.json
examples/dataset2/info_day5.json
examples/dataset2/session_day1.bin
examples/dataset2/session_day3.bin
examples/dataset2/session_day4.bin
examples/dataset2/session_day5.bin
misc/demo_redis_mocking.py
notebooks/old_tutorials/01_orcapod_core_concepts copy.ipynb
notebooks/old_tutorials/02_orcapod_basic_usage copy.ipynb
notebooks/old_tutorials/02_orcapod_basic_usage.ipynb
notebooks/old_tutorials/03_orcacapod_qol_features.ipynb
notebooks/old_tutorials/04_orcapod_tracker.ipynb
notebooks/old_tutorials/05_orcabridge_dj_integration.ipynb
notebooks/tutorials/01_introduction_to_orcapod.ipynb
notebooks/tutorials/02_parallel_execution_on_ray.ipynb
src/orcapod/__init__.py
src/orcapod/_version.py
src/orcapod/config.py
src/orcapod/errors.py
src/orcapod/py.typed
src/orcapod/types.py
src/orcapod.egg-info/PKG-INFO
src/orcapod.egg-info/SOURCES.txt
src/orcapod.egg-info/dependency_links.txt
src/orcapod.egg-info/requires.txt
src/orcapod.egg-info/top_level.txt
src/orcapod/contexts/__init__.py
src/orcapod/contexts/core.py
src/orcapod/contexts/registry.py
src/orcapod/contexts/data/v0.1.json
src/orcapod/contexts/data/schemas/context_schema.json
src/orcapod/core/__init__.py
src/orcapod/core/arrow_data_utils.py
src/orcapod/core/base.py
src/orcapod/core/kernels.py
src/orcapod/core/pods.py
src/orcapod/core/polars_data_utils.py
src/orcapod/core/system_constants.py
src/orcapod/core/trackers.py
src/orcapod/core/datagrams/__init__.py
src/orcapod/core/datagrams/arrow_datagram.py
src/orcapod/core/datagrams/arrow_tag_packet.py
src/orcapod/core/datagrams/base.py
src/orcapod/core/datagrams/dict_datagram.py
src/orcapod/core/datagrams/dict_tag_packet.py
src/orcapod/core/operators/__init__.py
src/orcapod/core/operators/base.py
src/orcapod/core/operators/batch.py
src/orcapod/core/operators/column_selection.py
src/orcapod/core/operators/filters.py
src/orcapod/core/operators/join.py
src/orcapod/core/operators/mappers.py
src/orcapod/core/operators/semijoin.py
src/orcapod/core/sources/__init__.py
src/orcapod/core/sources/arrow_table_source.py
src/orcapod/core/sources/base.py
src/orcapod/core/sources/csv_source.py
src/orcapod/core/sources/data_frame_source.py
src/orcapod/core/sources/delta_table_source.py
src/orcapod/core/sources/dict_source.py
src/orcapod/core/sources/list_source.py
src/orcapod/core/sources/manual_table_source.py
src/orcapod/core/sources/source_registry.py
src/orcapod/core/streams/__init__.py
src/orcapod/core/streams/base.py
src/orcapod/core/streams/cached_pod_stream.py
src/orcapod/core/streams/kernel_stream.py
src/orcapod/core/streams/lazy_pod_stream.py
src/orcapod/core/streams/pod_node_stream.py
src/orcapod/core/streams/table_stream.py
src/orcapod/core/streams/wrapped_stream.py
src/orcapod/databases/__init__.py
src/orcapod/databases/basic_delta_lake_arrow_database.py
src/orcapod/databases/delta_lake_databases.py
src/orcapod/databases/file_utils.py
src/orcapod/databases/legacy/delta_table_arrow_data_store.py
src/orcapod/databases/legacy/dict_data_stores.py
src/orcapod/databases/legacy/dict_transfer_data_store.py
src/orcapod/databases/legacy/legacy_arrow_data_stores.py
src/orcapod/databases/legacy/safe_dir_data_store.py
src/orcapod/databases/legacy/types.py
src/orcapod/execution_engines/__init__.py
src/orcapod/execution_engines/ray_execution_engine.py
src/orcapod/hashing/__init__.py
src/orcapod/hashing/arrow_hashers.py
src/orcapod/hashing/arrow_serialization.py
src/orcapod/hashing/arrow_utils.py
src/orcapod/hashing/defaults.py
src/orcapod/hashing/file_hashers.py
src/orcapod/hashing/function_info_extractors.py
src/orcapod/hashing/hash_utils.py
src/orcapod/hashing/legacy_core.py
src/orcapod/hashing/object_hashers.py
src/orcapod/hashing/semantic_type_hashers.py
src/orcapod/hashing/string_cachers.py
src/orcapod/hashing/types.py
src/orcapod/hashing/visitors.py
src/orcapod/pipeline/__init__.py
src/orcapod/pipeline/graph.py
src/orcapod/pipeline/nodes.py
src/orcapod/protocols/__init__.py
src/orcapod/protocols/database_protocols.py
src/orcapod/protocols/hashing_protocols.py
src/orcapod/protocols/legacy_data_protocols.py
src/orcapod/protocols/pipeline_protocols.py
src/orcapod/protocols/semantic_types_protocols.py
src/orcapod/protocols/core_protocols/__init__.py
src/orcapod/protocols/core_protocols/base.py
src/orcapod/protocols/core_protocols/datagrams.py
src/orcapod/protocols/core_protocols/kernel.py
src/orcapod/protocols/core_protocols/pods.py
src/orcapod/protocols/core_protocols/source.py
src/orcapod/protocols/core_protocols/streams.py
src/orcapod/protocols/core_protocols/trackers.py
src/orcapod/semantic_types/__init__.py
src/orcapod/semantic_types/precomputed_converters.py
src/orcapod/semantic_types/pydata_utils.py
src/orcapod/semantic_types/semantic_registry.py
src/orcapod/semantic_types/semantic_struct_converters.py
src/orcapod/semantic_types/type_inference.py
src/orcapod/semantic_types/universal_converter.py
src/orcapod/utils/__init__.py
src/orcapod/utils/arrow_utils.py
src/orcapod/utils/function_info.py
src/orcapod/utils/git_utils.py
src/orcapod/utils/lazy_module.py
src/orcapod/utils/name.py
src/orcapod/utils/object_spec.py
src/orcapod/utils/types_utils.py
tests/__init__.py
tests/test_data/__init__.py
tests/test_data/test_datagrams/__init__.py
tests/test_data/test_datagrams/test_arrow_datagram.py
tests/test_data/test_datagrams/test_arrow_tag_packet.py
tests/test_data/test_datagrams/test_base_integration.py
tests/test_data/test_datagrams/test_dict_datagram.py
tests/test_data/test_datagrams/test_dict_tag_packet.py
tests/test_hashing/__init__.py
tests/test_hashing/generate_file_hashes.py
tests/test_hashing/generate_hash_examples.py
tests/test_hashing/generate_pathset_packet_hashes.py
tests/test_hashing/test_basic_composite_hasher.py
tests/test_hashing/test_basic_hashing.py
tests/test_hashing/test_cached_file_hasher.py
tests/test_hashing/test_default_file_hasher.py
tests/test_hashing/test_file_hashes.py
tests/test_hashing/test_hash_samples.py
tests/test_hashing/test_hasher_factory.py
tests/test_hashing/test_hasher_parity.py
tests/test_hashing/test_legacy_composite_hasher.py
tests/test_hashing/test_packet_hasher.py
tests/test_hashing/test_path_set_hasher.py
tests/test_hashing/test_pathset_and_packet.py
tests/test_hashing/test_pathset_packet_hashes.py
tests/test_hashing/test_process_structure.py
tests/test_hashing/test_sqlite_cacher.py
tests/test_hashing/test_string_cachers.py
tests/test_hashing/hash_samples/file_hash_lut.json
tests/test_hashing/hash_samples/packet_hash_lut.json
tests/test_hashing/hash_samples/pathset_hash_lut.json
tests/test_hashing/hash_samples/data_structures/hash_examples_20250524_061711.json
tests/test_hashing/hash_samples/file_samples/sample_binary_100kb.bin
tests/test_hashing/hash_samples/file_samples/sample_binary_10kb.bin
tests/test_hashing/hash_samples/file_samples/sample_binary_1kb.bin
tests/test_hashing/hash_samples/file_samples/sample_binary_50kb.bin
tests/test_hashing/hash_samples/file_samples/sample_binary_5kb.bin
tests/test_hashing/hash_samples/file_samples/sample_structured.json
tests/test_hashing/hash_samples/file_samples/sample_text_100kb.txt
tests/test_hashing/hash_samples/file_samples/sample_text_10kb.txt
tests/test_hashing/hash_samples/file_samples/sample_text_1kb.txt
tests/test_hashing/hash_samples/file_samples/sample_text_50kb.txt
tests/test_hashing/hash_samples/file_samples/sample_text_5kb.txt
tests/test_hashing/test_string_cacher/__init__.py
tests/test_hashing/test_string_cacher/test_file_cacher.py
tests/test_hashing/test_string_cacher/test_in_memory_cacher.py
tests/test_hashing/test_string_cacher/test_redis_cacher.py
tests/test_hashing/test_string_cacher/test_sqlite_cacher.py
tests/test_semantic_types/test_path_struct_converter.py
tests/test_semantic_types/test_pydata_utils.py
tests/test_semantic_types/test_semantic_registry.py
tests/test_semantic_types/test_semantic_struct_converters.py
tests/test_semantic_types/test_universal_converter.py
tests/test_store/__init__.py
tests/test_store/conftest.py
tests/test_store/test_dir_data_store.py
tests/test_store/test_integration.py
tests/test_store/test_noop_data_store.py
tests/test_store/test_transfer_data_store.py
tests/test_types/__init__.py
tests/test_types/test_inference/__init__.py
tests/test_types/test_inference/test_extract_function_data_types.py