Registry /
workflow / apache-airflow-providers-apache-pinot
Install & Compatibility
Where this runs
tested against v4.10.3 · pip install
no network on importno background threads
Install × environment matrix
Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux
muslpy 3.10–3.95 runs
installs and imports cleanly · install 0.0s · import 0.000s · 251.1MB
glibcpy 3.10–3.95 runs
installs and imports cleanly · install 23.4s · import 0.000s · 249MB
251MB installed
● package 251MB
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
PinotAdminHook
✓ from airflow.providers.apache.pinot.hooks.pinot_admin import PinotAdminHook
✗ from airflow.providers.apache.pinot.hooks.pinot_admin import PinotAdminHook
Basic DAG using Pinot operators and hooks. Requires a running Pinot cluster.
from datetime import datetime
from airflow import DAG
from airflow.providers.apache.pinot.hooks.pinot import PinotDbApiHook
from airflow.providers.apache.pinot.operators.pinot_table_create_or_update import PinotTableCreateOrUpdateOperator
with DAG(
dag_id='pinot_example',
start_date=datetime(2025, 1, 1),
catchup=False,
) as dag:
# Example: create a Pinot table
create_table = PinotTableCreateOrUpdateOperator(
task_id='create_pinot_table',
table_config={
'tableName': 'myTable',
'tableType': 'OFFLINE',
'segmentsConfig': {
'replication': '1',
'schemaName': 'mySchema'
}
},
pinot_admin_hook=PinotAdminHook(pinot_admin_host='http://localhost:9000'),
)
Upgrade
Version history
4.10.3latest on PyPI · released Jun 7, 2026
Audit
Dependencies
apache-airflowrequiredRequired runtime dependency
pinotdbrequiredRequired for DBAPI hook
pinot-adminoptionalRequired for cluster management hooks (PinotAdminHook)