Metadata-Version: 2.1
Name: intake-dal
Version: 0.1.7
Summary: Intake single YAML hierarchical catalog.
Author: Zillow AI Platform
Requires-Python: >=3.6
Classifier: Development Status :: 2 - Pre-Alpha
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Natural Language :: English
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Provides-Extra: doc
Requires-Dist: deepmerge (==0.1.0)
Requires-Dist: intake (==0.5.4)
Requires-Dist: intake-nested-yaml-catalog (==0.1.0)
Requires-Dist: pandavro (>=1.5.1,<2.0.0)
Requires-Dist: pyarrow (>=0.15.1,<0.16.0)
Requires-Dist: pyyaml (==5.1.2)
Requires-Dist: toolz (>=0.10.0,<0.11.0)
Requires-Dist: vcver (>=0.2.10)
Description-Content-Type: text/x-rst

.. image:: https://travis-ci.org/zillow/intake-dal.svg?branch=master
    :target: https://travis-ci.org/zillow/intake-dal

.. image:: https://coveralls.io/repos/github/zillow/intake-dal/badge.svg?branch=master
    :target: https://coveralls.io/github/zillow/intake-dal?branch=master

.. image:: https://readthedocs.org/projects/intake-dal/badge/?version=latest
    :target: https://intake-dal.readthedocs.io/en/latest/?badge=latest
    :alt: Documentation Status


Welcome to Intake DAL (data access layer) plugin
==================================================
This `Intake <https://intake.readthedocs.io/en/latest/quickstart.html>`_ plugin helps
abstract a dataset over disparate storage systems (eg: bulk, streaming, serving, ...).
It also provides an easy way to specialize a
`hierarchical catalog <https://github.com/zillow/intake-nested-yaml-catalog/>`_
to a default DAL storage system.


Sample Catalog source entry:

.. code-block:: yaml

    user_events:
      driver: dal
      args:
        default: 'local'
        storage:
          local: 'csv://{{ CATALOG_DIR }}/data/user_events.csv'
          serving: 'in-memory-kv://foo'
          batch: 'parquet://{{ CATALOG_DIR }}/data/user_events.parquet'

Example code using sample catalog:

.. code-block:: python

  # Specialize the catalog dal default storge mode datasources
  # to be "serving".
  cat = DalCatalog(path, storage_mode="serving")

  # reads from the serving storage system
  # using the in-memory-kv Intake plugin
  df = cat.user_events.read()



