apache-airflow-providers-apache-pinot

What it is and what it does

This is an Apache Airflow provider package that bridges Airflow workflows with Apache Pinot, a real-time analytics database. It supplies operators and hooks to execute SQL queries against Pinot clusters, manage connections, and integrate Pinot operations into Airflow DAGs. The package is built on top of Airflow's common SQL and compatibility providers, and uses pinotdb as its underlying connection driver.

The package is part of the official Airflow provider ecosystem, maintained by the Apache Software Foundation, and supports current Python versions (3.10 through 3.14). It is designed for teams running Airflow orchestration who need to query or interact with Pinot clusters as part of their data pipelines.

Use it for:

• Schedule and orchestrate SQL queries against Pinot tables as part of larger Airflow data workflows.
• Build real-time analytics pipelines that pull data from Pinot into downstream systems.
• Monitor Pinot cluster health and query performance by embedding Pinot operations in Airflow monitoring DAGs.
• Automate ETL tasks that involve querying Pinot and transforming results for reporting or further processing.

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Integrates Apache Pinot with Apache Airflow, providing operators and hooks to query and manage Pinot clusters as part of Airflow data pipelines.

Yes. This is an actively maintained, production-stable provider package from the Apache Airflow project with no known vulnerabilities. Install it if you run Airflow and need to query or manage Apache Pinot clusters. The low install friction, permissive license, and tight integration with Airflow's SQL ecosystem make it a straightforward choice for Pinot users in Airflow environments.

Install

apache-airflow-providers-apache-pinot on PyPI

pip install apache-airflow-providers-apache-pinot

uv add apache-airflow-providers-apache-pinot

poetry add apache-airflow-providers-apache-pinot

Installing apache-airflow-providers-apache-pinot

Before you install

Low friction install as a pure-Python wheel. Actively maintained with recent releases; requires Apache Airflow >=2.11.0 and pinotdb >=5.1.0 as runtime dependencies.

License in practice

Apache License 2.0 (permissive). You may use, modify, and distribute this package freely in commercial and private projects, provided you include the license notice.

Quickstart

pip install apache-airflow-providers-apache-pinot

from airflow.providers.apache.pinot.operators.pinot import PinotOperator
from airflow import DAG

with DAG('pinot_query_dag') as dag:
    query_task = PinotOperator(
        task_id='query_pinot',
        sql='SELECT * FROM table_name LIMIT 10',
        pinot_conn_id='pinot_default'
    )

Requires an existing Apache Airflow installation (>=2.11.0) and a configured Pinot connection in Airflow.

Verify before relying

• Specific operators and hooks available beyond basic query execution
• Support for Pinot-specific features (real-time tables, segments, etc.)
• Whether cross-provider extras (common.compat, common.sql) are required for typical use

Package facts

Evidence: apache_airflow_providers_apache_pinot-4.10.3-py3-none-any.whl

Keywords: airflow-provider, apache.pinot, airflow, integration

Tags

More Monitoring packages