Skip to main content

Distributed Dataframes for Multimodal Data

Project description

Daft dataframes can load any data such as PDF documents, images, protobufs, csv, parquet and audio files into a table dataframe structure for easy querying

Github Actions tests PyPI latest tag Coverage slack community

WebsiteDocsInstallation10-minute tour of DaftCommunity and Support

Daft: Distributed dataframes for multimodal data

Daft is a distributed query engine for large-scale data processing in Python and is implemented in Rust.

  • Familiar interactive API: Lazy Python Dataframe for rapid and interactive iteration

  • Focus on the what: Powerful Query Optimizer that rewrites queries to be as efficient as possible

  • Data Catalog integrations: Full integration with data catalogs such as Apache Iceberg

  • Rich multimodal type-system: Supports multimodal types such as Images, URLs, Tensors and more

  • Seamless Interchange: Built on the Apache Arrow In-Memory Format

  • Built for the cloud: Record-setting I/O performance for integrations with S3 cloud storage

Table of Contents

About Daft

Daft was designed with the following principles in mind:

  1. Any Data: Beyond the usual strings/numbers/dates, Daft columns can also hold complex or nested multimodal data such as Images, Embeddings and Python objects efficiently with it’s Arrow based memory representation. Ingestion and basic transformations of multimodal data is extremely easy and performant in Daft.

  2. Interactive Computing: Daft is built for the interactive developer experience through notebooks or REPLs - intelligent caching/query optimizations accelerates your experimentation and data exploration.

  3. Distributed Computing: Some workloads can quickly outgrow your local laptop’s computational resources - Daft integrates natively with Ray for running dataframes on large clusters of machines with thousands of CPUs/GPUs.

Getting Started

Installation

Install Daft with pip install getdaft.

For more advanced installations (e.g. installing from source or with extra dependencies such as Ray and AWS utilities), please see our Installation Guide

Quickstart

Check out our 10-minute quickstart!

In this example, we load images from an AWS S3 bucket’s URLs and resize each image in the dataframe:

import daft

# Load a dataframe from filepaths in an S3 bucket
df = daft.from_glob_path("s3://daft-public-data/laion-sample-images/*")

# 1. Download column of image URLs as a column of bytes
# 2. Decode the column of bytes into a column of images
df = df.with_column("image", df["path"].url.download().image.decode())

# Resize each image into 32x32
df = df.with_column("resized", df["image"].image.resize(32, 32))

df.show(3)

Dataframe code to load a folder of images from AWS S3 and create thumbnails

Benchmarks

Benchmarks for SF100 TPCH

To see the full benchmarks, detailed setup, and logs, check out our benchmarking page.

More Resources

  • 10-minute tour of Daft - learn more about Daft’s full range of capabilities including dataloading from URLs, joins, user-defined functions (UDF), groupby, aggregations and more.

  • User Guide - take a deep-dive into each topic within Daft

  • API Reference - API reference for public classes/functions of Daft

Contributing

To start contributing to Daft, please read CONTRIBUTING.md

Here’s a list of good first issues to get yourself warmed up with Daft. Comment in the issue to pick it up, and feel free to ask any questions!

Telemetry

To help improve Daft, we collect non-identifiable data.

To disable this behavior, set the following environment variable: DAFT_ANALYTICS_ENABLED=0

The data that we collect is:

  1. Non-identifiable: events are keyed by a session ID which is generated on import of Daft

  2. Metadata-only: we do not collect any of our users’ proprietary code or data

  3. For development only: we do not buy or sell any user data

Please see our documentation for more details.

https://static.scarf.sh/a.png?x-pxid=cd444261-469e-473b-b9ba-f66ac3dc73ee

License

Daft has an Apache 2.0 license - please see the LICENSE file.

Project details


Release history Release notifications | RSS feed

This version

0.3.5

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

getdaft-0.3.5.tar.gz (3.7 MB view details)

Uploaded Source

Built Distributions

getdaft-0.3.5-cp38-abi3-win_amd64.whl (26.5 MB view details)

Uploaded CPython 3.8+ Windows x86-64

getdaft-0.3.5-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl (29.5 MB view details)

Uploaded CPython 3.8+ manylinux: glibc 2.17+ x86-64

getdaft-0.3.5-cp38-abi3-manylinux_2_17_aarch64.manylinux2014_aarch64.whl (28.0 MB view details)

Uploaded CPython 3.8+ manylinux: glibc 2.17+ ARM64

getdaft-0.3.5-cp38-abi3-macosx_11_0_arm64.whl (24.5 MB view details)

Uploaded CPython 3.8+ macOS 11.0+ ARM64

getdaft-0.3.5-cp38-abi3-macosx_10_12_x86_64.whl (26.5 MB view details)

Uploaded CPython 3.8+ macOS 10.12+ x86-64

File details

Details for the file getdaft-0.3.5.tar.gz.

File metadata

  • Download URL: getdaft-0.3.5.tar.gz
  • Upload date:
  • Size: 3.7 MB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/5.1.1 CPython/3.11.10

File hashes

Hashes for getdaft-0.3.5.tar.gz
Algorithm Hash digest
SHA256 69a09b2d150a4ea0f3cf2e6d18af72a197516b3ef37c07677f84a7ad5a6b2652
MD5 16b55610681b99026a7445cf82f604ec
BLAKE2b-256 4d7a872d452817448aad58333b770f7261578e8466821be91cea30eb97970489

See more details on using hashes here.

File details

Details for the file getdaft-0.3.5-cp38-abi3-win_amd64.whl.

File metadata

  • Download URL: getdaft-0.3.5-cp38-abi3-win_amd64.whl
  • Upload date:
  • Size: 26.5 MB
  • Tags: CPython 3.8+, Windows x86-64
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/5.1.1 CPython/3.11.10

File hashes

Hashes for getdaft-0.3.5-cp38-abi3-win_amd64.whl
Algorithm Hash digest
SHA256 34e9656f6111d02a0c72330da1d4d68d66af4fd155445c4130361f5f87ccfc92
MD5 3828eae9cce50a4921f6ca6b89389b79
BLAKE2b-256 44c56f761783417d5802f55c70e6e8fe0c2eaf200109dd7c00f2a5a54a394de9

See more details on using hashes here.

File details

Details for the file getdaft-0.3.5-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.

File metadata

File hashes

Hashes for getdaft-0.3.5-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
Algorithm Hash digest
SHA256 92fc754eca0c9cd9590817cb2c8d158bf4116b9f14cf310146518e93b0a6e97b
MD5 61864c7cb8de7bada0a563ed6bfb2934
BLAKE2b-256 f4a9fcc28c6f698ed2554cbbd94e6ffaa8bf4a10e636eeeeff8c8c3b9caeb792

See more details on using hashes here.

File details

Details for the file getdaft-0.3.5-cp38-abi3-manylinux_2_17_aarch64.manylinux2014_aarch64.whl.

File metadata

File hashes

Hashes for getdaft-0.3.5-cp38-abi3-manylinux_2_17_aarch64.manylinux2014_aarch64.whl
Algorithm Hash digest
SHA256 17ef27e651832af9c231a148167c1cb815052b9fdc2feb611ff567b26300ee47
MD5 fd28a42cd9570250f9401a864c5ae244
BLAKE2b-256 02484b77a757e206e07c1d2d92836b9a4378f6b193500cf0631fdea1883c338e

See more details on using hashes here.

File details

Details for the file getdaft-0.3.5-cp38-abi3-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for getdaft-0.3.5-cp38-abi3-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 10e2afd2742d790da836803aa03d4c11c8c9a1aaf950ca00e0920726392d2515
MD5 35d597a79cc23a791b8c2dc35604b66b
BLAKE2b-256 ed18a1cb241c720a0ba81dab4aa83879131ff68b203307d61390d312048bb5cd

See more details on using hashes here.

File details

Details for the file getdaft-0.3.5-cp38-abi3-macosx_10_12_x86_64.whl.

File metadata

File hashes

Hashes for getdaft-0.3.5-cp38-abi3-macosx_10_12_x86_64.whl
Algorithm Hash digest
SHA256 263879c3ee252da6ad8e274f96f7b750278f9a9e3847c14d1fc2381e1ef82e9f
MD5 22831d5a8489710ca009e2c5af8919f8
BLAKE2b-256 173cbaa5999c88276ff5b0f82a1cec9f68db22b188e5c46c45cc617543cdc6cd

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page