description |
---|
This section describes quick start commands that launch all Pinot components in a single process. |
Pinot ships with QuickStart commands that launch Pinot components in a single process and import pre-built datasets. These QuickStarts are a good place if you're just getting started with Pinot.
{% hint style="info" %} Prerequisites
You will need to have installed Pinot locally or have Docker installed if you want to use the Pinot Docker image. {% endhint %}
{% hint style="warning" %} macOS Monterey Users
By default the Airplay receiver server runs on port 7000, which is also the port used by the Pinot Server in the Quick Start. You may see the following error when running these examples:
Failed to start a Pinot [SERVER]
java.lang.RuntimeException: java.net.BindException: Address already in use
at org.apache.pinot.core.transport.QueryServer.start(QueryServer.java:103) ~[pinot-all-0.9.0-jar-with-dependencies.jar:0.9.0-cf8b84e8b0d6ab62374048de586ce7da21132906]
at org.apache.pinot.server.starter.ServerInstance.start(ServerInstance.java:158) ~[pinot-all-0.9.0-jar-with-dependencies.jar:0.9.0-cf8b84e8b0d6ab62374048de586ce7da21132906]
at org.apache.helix.manager.zk.ParticipantManager.handleNewSession(ParticipantManager.java:110) ~[pinot-all-0.9.0-jar-with-dependencies.jar:0.9.0-cf8b84e8b0d6ab62374048de586ce7da2113
If you disable the Airplay receiver server and try again, you shouldn't see this error message anymore. {% endhint %}
This example demonstrates how to do batch processing with Pinot. The command:
- Starts Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates the
baseballStats
table - Launches a standalone data ingestion job that builds one segment for a given CSV data file for the
baseballStats
table and pushes the segment to the Pinot Controller. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type batch
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type batch
{% endtab %} {% endtabs %}
This example demonstrates how to import and query JSON documents in Pinot. The command:
- Starts Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates the
githubEvents
table - Launches a standalone data ingestion job that builds one segment for a given JSON data file for the
githubEvents
table and pushes the segment to the Pinot Controller. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type batch_json_index
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type batch_json_index
{% endtab %} {% endtabs %}
This example demonstrates how to do batch processing in Pinot where the the data items have complex fields that need to be unnested. The command:
- Starts Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates the
githubEvents
table - Launches a standalone data ingestion job that builds one segment for a given JSON data file for the
githubEvents
table and pushes the segment to the Pinot Controller. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type batch_json_index
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type batch_json_index
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing with Pinot. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates
meetupRsvp
table - Launches a
meetup
stream - Publishes data to a Kafka topic
meetupRSVPEvents
that is subscribed to by Pinot. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type stream
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type stream
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing with JSON documents in Pinot. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates
meetupRsvp
table - Launches a
meetup
stream - Publishes data to a Kafka topic
meetupRSVPEvents
that is subscribed to by Pinot - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type stream_json_index
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type stream_json_index
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing in Pinot with RealtimeToOfflineSegmentsTask and MergeRollupTask minion tasks continuously optimizing segments as data gets ingested. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, Pinot Minion, and Pinot Server.
- Creates
githubEvents
table - Launches a GitHub events stream
- Publishes data to a Kafka topic
githubEvents
that is subscribed to by Pinot. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type realtime_minion
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type realtime_minion
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing in Pinot where the stream contains items that have complex fields that need to be unnested. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, Pinot Minion, and Pinot Server.
- Creates
meetupRsvp
table - Launches a
meetup
stream - Publishes data to a Kafka topic
meetupRSVPEvents
that is subscribed to by Pinot. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type stream_complex_type
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type stream_complex_type
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing with upsert with Pinot. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates
meetupRsvp
table - Launches a
meetup
stream - Publishes data to a Kafka topic
meetupRSVPEvents
that is subscribed to by Pinot - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type upsert
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type upsert
{% endtab %} {% endtabs %}
This example demonstrates how to do stream processing with upsert with JSON documents in Pinot. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates
meetupRsvp
table - Launches a
meetup
stream - Publishes data to a Kafka topic
meetupRSVPEvents
that is subscribed to by Pinot - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type upsert_json_index
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type upsert_json_index
{% endtab %} {% endtabs %}
This example demonstrates how to do hybrid stream and batch processing with Pinot. The command:
- Starts Apache Kafka, Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server.
- Creates
airlineStats
table - Launches a standalone data ingestion job that builds segments under a given directory of Avro files for the
airlineStats
table and pushes the segments to the Pinot Controller. - Launches a stream of flights stats
- Publishes data to a Kafka topic
airlineStatsEvents
that is subscribed to by Pinot. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type hybrid
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type hybrid
{% endtab %} {% endtabs %}
This example demonstrates how to do joins in Pinot using the Lookup UDF. The command:
- Starts Apache Zookeeper, Pinot Controller, Pinot Broker, and Pinot Server in the same container.
- Creates the
baseballStats
table - Launches a data ingestion job that builds one segment for a given CSV data file for the
baseballStats
table and pushes the segment to the Pinot Controller. - Creates the
dimBaseballTeams
table - Launches a data ingestion job that builds one segment for a given CSV data file for the
dimBaseballStats
table and pushes the segment to the Pinot Controller. - Issues sample queries to Pinot
{% tabs %} {% tab title="Docker" %}
docker run \
-p 9000:9000 \
apachepinot/pinot:0.9.3 QuickStart \
-type join
{% endtab %}
{% tab title="Launcher scripts" %}
./bin/pinot-admin.sh QuickStart -type join
{% endtab %} {% endtabs %}