Streaming Sources
Real-time ingestion into native Pinot tables.Apache Kafka
Create a connection to stream real-time events from Apache Kafka into StarTree.
Confluent Cloud
Connect to fully managed Kafka in Confluent Cloud and ingest with API key authentication.
AWS MSK
Connect to Amazon MSK using IAM-based SASL authentication over TLS.
Amazon Kinesis
Create a connection to ingest real-time data from Amazon Kinesis streams.
Redpanda
Create a connection for high-performance streaming ingestion from Redpanda.
StreamNative
Ingest from fully managed Kafka in StreamNative using SASL_SSL with PLAIN authentication.
Aiven
Create a connection to ingest data from Aiven’s managed Apache Kafka service.
WarpStream
Stream data into StarTree using WarpStream’s Kafka-compatible API.
Batch Sources
Batch loads copied into Pinot segments.Amazon S3
Create a connection to ingest files stored in Amazon S3 buckets.
Google Cloud Storage
Create a connection to ingest files from Google Cloud Storage.
Azure ADLS
Create a connection to ingest files from Azure Data Lake Storage.
Delta Lake
Ingest from Delta Lake hosted in S3 or GCS using a custom connection.
Snowflake
Create a connection to load batch data from Snowflake into StarTree Cloud.
BigQuery
Create a connection to load data from Google BigQuery tables and views.
File Upload
Upload a file up to 30MB in AVRO, CSV, JSON, Parquet, ProtoBuf, or ORC.
Custom Connection
Connect to any batch or streaming data source using the custom connector.
External Tables
Query Iceberg catalogs and raw Parquet in place — no copy, no ETL.AWS Glue
Connect an AWS Glue Iceberg catalog as an External Table with the Data Portal wizard — no API calls.
Amazon S3 Tables
Connect an Amazon S3 Tables bucket as an External Table with the point-and-click Data Portal wizard.
Unity Catalog
Connect Databricks or OSS Unity Catalog, including Delta tables with UniForm, via the Data Portal wizard.
Apache Polaris & Snowflake Open Catalog
Connect Polaris or Snowflake Open Catalog Iceberg tables via the wizard using OAuth2 principal credentials.
Snowflake Horizon Catalog
Connect Snowflake-managed Iceberg tables (Horizon) via the Data Portal wizard, authenticating with a PAT.
S3 Data Lake
Query raw Parquet files in an S3 bucket as an External Table — no catalog service required.
GCS Data Lake
Connect raw Parquet files on GCS via the S3-compatible interop endpoint using the Data Portal wizard.
Support Matrix
See supported catalogs, table and file formats, auth methods, features, indexes, and limits in one place.
Message Formats & Decoders
Payload formats supported on the streaming ingestion path.JSON
Decode JSON-formatted messages from Kafka topics into Pinot rows during real-time ingestion.
Avro
Ingest Avro-encoded Kafka messages using schemas managed in Confluent Schema Registry.
Protobuf
Ingest Protobuf-encoded Kafka messages with schemas from Confluent Schema Registry.
Debezium CDC
Consume Debezium CDC data from MySQL or Postgres in real time via Kafka or Kinesis.
DynamoDB
Ingest DynamoDB Streams CDC data in real time without complex transformations.
Prometheus
Ingest Prometheus-formatted metrics data natively into Pinot tables.
AWS Glue Schema Registry
Decode Avro messages from Kafka or MSK with schemas managed in AWS Glue Schema Registry.
Language Clients & APIs
Query StarTree Cloud from your application.Java
Query your cluster with Pinot’s native, tenant-aware Java client via Maven or Gradle.
Python
Query StarTree Cloud from Python applications using the pinotdb client library.
Node.js
Query Pinot from Node.js applications using a sample axios-based client driver.
REST API
Run SQL over HTTP by POSTing queries to the Pinot broker’s /query/sql endpoint.
Pinot Proxy
Route queries to the right broker tenant and access advanced query, cursor, routing, and debug APIs.
StarTree MCP
Deploy an MCP server for agentic workflows and natural-language queries on Pinot tables.
Visualization & BI
Connect BI tools to StarTree Cloud.Tableau
Connect Tableau Desktop or Tableau Server to StarTree Cloud using the JDBC driver and TACO connector.
Superset
Connect Apache Superset to StarTree Cloud with a SQLAlchemy URI to visualize your data.
Export
Write Pinot data back to your lake.Data Export Task
Export completed Pinot REALTIME segments as Parquet to a filesystem or Iceberg REST catalog.