Apache Druid
  • Technology
  • Use Cases
  • Powered By
  • Docs
  • Community
  • Apache
  • Download

›Tutorials

Getting started

  • Introduction to Apache Druid
  • Quickstart (local)
  • Single server deployment
  • Clustered deployment

Tutorials

  • Load files using SQL
  • Load from Apache Kafka
  • Load from Apache Hadoop
  • Query data
  • Aggregate data with rollup
  • Theta sketches
  • Configure data retention
  • Update existing data
  • Compact segments
  • Deleting data
  • Write an ingestion spec
  • Transform input data
  • Convert ingestion spec to SQL
  • Run with Docker
  • Kerberized HDFS deep storage
  • Get to know Query view
  • Unnesting arrays
  • Query from deep storage
  • Jupyter Notebook tutorials
  • Docker for tutorials
  • JDBC connector

Design

  • Design
  • Segments
  • Processes and servers
  • Deep storage
  • Metadata storage
  • ZooKeeper

Ingestion

  • Overview
  • Ingestion concepts

    • Source input formats
    • Input sources
    • Schema model
    • Rollup
    • Partitioning
    • Task reference

    SQL-based batch

    • SQL-based ingestion
    • Key concepts
    • Security
    • Examples
    • Reference
    • Known issues

    Streaming

    • Apache Kafka ingestion
    • Apache Kafka supervisor
    • Apache Kafka operations
    • Amazon Kinesis

    Classic batch

    • JSON-based batch
    • Hadoop-based
  • Ingestion spec reference
  • Schema design tips
  • Troubleshooting FAQ

Data management

  • Overview
  • Data updates
  • Data deletion
  • Schema changes
  • Compaction
  • Automatic compaction

Querying

    Druid SQL

    • Overview and syntax
    • Query from deep storage
    • SQL data types
    • Operators
    • Scalar functions
    • Aggregation functions
    • Array functions
    • Multi-value string functions
    • JSON functions
    • All functions
    • SQL query context
    • SQL metadata tables
    • SQL query translation
  • Native queries
  • Query execution
  • Troubleshooting
  • Concepts

    • Datasources
    • Joins
    • Lookups
    • Multi-value dimensions
    • Nested columns
    • Multitenancy
    • Query caching
    • Using query caching
    • Query context

    Native query types

    • Timeseries
    • TopN
    • GroupBy
    • Scan
    • Search
    • TimeBoundary
    • SegmentMetadata
    • DatasourceMetadata

    Native query components

    • Filters
    • Granularities
    • Dimensions
    • Aggregations
    • Post-aggregations
    • Expressions
    • Having filters (groupBy)
    • Sorting and limiting (groupBy)
    • Sorting (topN)
    • String comparators
    • Virtual columns
    • Spatial filters

API reference

  • Overview
  • HTTP APIs

    • Druid SQL
    • SQL-based ingestion
    • JSON querying
    • Tasks
    • Supervisors
    • Retention rules
    • Data management
    • Automatic compaction
    • Lookups
    • Service status
    • Dynamic configuration
    • Legacy metadata

    Java APIs

    • SQL JDBC driver

Configuration

  • Configuration reference
  • Extensions
  • Logging

Operations

  • Web console
  • Java runtime
  • Durable storage
  • Security

    • Security overview
    • User authentication and authorization
    • LDAP auth
    • Password providers
    • Dynamic Config Providers
    • TLS support

    Performance tuning

    • Basic cluster tuning
    • Segment size optimization
    • Mixed workloads
    • HTTP compression
    • Automated metadata cleanup

    Monitoring

    • Request logging
    • Metrics
    • Alerts
  • High availability
  • Rolling updates
  • Using rules to drop and retain data
  • Migrate from firehose
  • Working with different versions of Apache Hadoop
  • Misc

    • dump-segment tool
    • reset-cluster tool
    • insert-segment-to-db tool
    • pull-deps tool
    • Deep storage migration
    • Export Metadata Tool
    • Metadata Migration
    • Content for build.sbt

Development

  • Developing on Druid
  • Creating extensions
  • JavaScript functionality
  • Build from source
  • Versioning
  • Contribute to Druid docs
  • Experimental features

Misc

  • Papers

Hidden

  • Apache Druid vs Elasticsearch
  • Apache Druid vs. Key/Value Stores (HBase/Cassandra/OpenTSDB)
  • Apache Druid vs Kudu
  • Apache Druid vs Redshift
  • Apache Druid vs Spark
  • Apache Druid vs SQL-on-Hadoop
  • Authentication and Authorization
  • Broker
  • Coordinator Process
  • Historical Process
  • Indexer Process
  • Indexing Service
  • MiddleManager Process
  • Overlord Process
  • Router Process
  • Peons
  • Approximate Histogram aggregators
  • Apache Avro
  • Microsoft Azure
  • Bloom Filter
  • DataSketches extension
  • DataSketches HLL Sketch module
  • DataSketches Quantiles Sketch module
  • DataSketches Theta Sketch module
  • DataSketches Tuple Sketch module
  • Basic Security
  • Kerberos
  • Cached Lookup Module
  • Apache Ranger Security
  • Google Cloud Storage
  • HDFS
  • Apache Kafka Lookups
  • Globally Cached Lookups
  • MySQL Metadata Store
  • ORC Extension
  • Druid pac4j based Security extension
  • Apache Parquet Extension
  • PostgreSQL Metadata Store
  • Protobuf
  • S3-compatible
  • Simple SSLContext Provider Module
  • Stats aggregator
  • Test Stats Aggregators
  • Druid AWS RDS Module
  • Kubernetes
  • Ambari Metrics Emitter
  • Apache Cassandra
  • Rackspace Cloud Files
  • DistinctCount Aggregator
  • Graphite Emitter
  • InfluxDB Line Protocol Parser
  • InfluxDB Emitter
  • Kafka Emitter
  • Materialized View
  • Moment Sketches for Approximate Quantiles module
  • Moving Average Query
  • OpenTSDB Emitter
  • Druid Redis Cache
  • Microsoft SQLServer
  • StatsD Emitter
  • T-Digest Quantiles Sketch module
  • Thrift
  • Timestamp Min/Max aggregators
  • GCE Extensions
  • Aliyun OSS
  • Prometheus Emitter
  • Firehose (deprecated)
  • JSON-based batch (simple)
  • Realtime Process
  • kubernetes
  • Cardinality/HyperUnique aggregators
  • Select
  • Load files natively
Edit

Docker for Jupyter Notebook tutorials

Apache Druid provides a custom Jupyter container that contains the prerequisites for all Jupyter-based Druid tutorials, as well as all of the tutorials themselves. You can run the Jupyter container, as well as containers for Druid and Apache Kafka, using the Docker Compose file provided in the Druid GitHub repository.

You can run the following combination of applications:

  • Jupyter only
  • Jupyter and Druid
  • Jupyter, Druid, and Kafka
  • Kafka and Jupyter

Prerequisites

Jupyter in Docker requires that you have Docker and Docker Compose. We recommend installing these through Docker Desktop.

For ARM-based devices, see Tutorial setup for ARM-based devices.

Launch the Docker containers

You run Docker Compose to launch Jupyter and optionally Druid or Kafka. Docker Compose references the configuration in docker-compose.yaml. Running Druid in Docker also requires the environment file, which sets the configuration properties for the Druid services. To get started, download both docker-compose.yaml and environment from tutorial-jupyter-docker.zip.

Alternatively, you can clone the Apache Druid repo and access the files in druid/examples/quickstart/jupyter-notebooks/docker-jupyter.

Start only the Jupyter container

If you already have Druid running locally or on another machine, you can run the Docker containers for Jupyter only. In the same directory as docker-compose.yaml, start the application:

docker compose --profile jupyter up -d

The Docker Compose file assigns 8889 for the Jupyter port. You can override the port number by setting the JUPYTER_PORT environment variable before starting the Docker application.

If Druid is running local to the same machine as Jupyter, open the tutorial and set the host variable to host.docker.internal before starting. For example:

host = "host.docker.internal"

Start Jupyter and Druid

Running Druid in Docker requires the environment file as well as an environment variable named DRUID_VERSION, which determines the version of Druid to use. The Druid version references the Docker tag to pull from the Apache Druid Docker Hub.

In the same directory as docker-compose.yaml and environment, start the application:

DRUID_VERSION={{DRUIDVERSION}} docker compose --profile druid-jupyter up -d

Start Jupyter, Druid, and Kafka

Running Druid in Docker requires the environment file as well as the DRUID_VERSION environment variable.

In the same directory as docker-compose.yaml and environment, start the application:

DRUID_VERSION={{DRUIDVERSION}} docker compose --profile all-services up -d

Start Kafka and Jupyter

If you already have Druid running externally, such as an existing cluster or a dedicated infrastructure for Druid, you can run the Docker containers for Kafka and Jupyter only.

In the same directory as docker-compose.yaml and environment, start the application:

DRUID_VERSION={{DRUIDVERSION}} docker compose --profile kafka-jupyter up -d

If you have an external Druid instance running on a different machine than the one hosting the Docker Compose environment, change the host variable in the notebook tutorial to the hostname or address of the machine where Druid is running.

If Druid is running local to the same machine as Jupyter, open the tutorial and set the host variable to host.docker.internal before starting. For example:

host = "host.docker.internal"

To enable Druid to ingest data from Kafka within the Docker Compose environment, update the bootstrap.servers property in the Kafka ingestion spec to localhost:9094 before ingesting. For reference, see more on consumer properties.

Update image from Docker Hub

If you already have a local cache of the Jupyter image, you can update the image before running the application using the following command:

docker compose pull jupyter

Use locally built image

The default Docker Compose file pulls the custom Jupyter Notebook image from a third party Docker Hub. If you prefer to build the image locally from the official source, do the following:

  1. Clone the Apache Druid repository.
  2. Navigate to examples/quickstart/jupyter-notebooks/docker-jupyter.
  3. Start the services using -f docker-compose-local.yaml in the docker compose command. For example:
DRUID_VERSION={{DRUIDVERSION}} docker compose --profile all-services -f docker-compose-local.yaml up -d

Access Jupyter-based tutorials

The following steps show you how to access the Jupyter notebook tutorials from the Docker container. At startup, Docker creates and mounts a volume to persist data from the container to your local machine. This way you can save your work completed within the Docker container.

  1. Navigate to the notebooks at http://localhost:8889.

    If you set JUPYTER_PORT to another port number, replace 8889 with the value of the Jupyter port.

  2. Select a tutorial. If you don't plan to save your changes, you can use the notebook directly as is. Otherwise, continue to the next step.

  3. Optional: To save a local copy of your tutorial work, select File > Save as... from the navigation menu. Then enter work/<notebook name>.ipynb. If the notebook still displays as read only, you may need to refresh the page in your browser. Access the saved files in the notebooks folder in your local working directory.

View the Druid web console

To access the Druid web console in Docker, go to http://localhost:8888/unified-console.html. Use the web console to view datasources and ingestion tasks that you create in the tutorials.

Stop Docker containers

Shut down the Docker application using the following command:

docker compose down -v

Tutorial setup without using Docker

To use the Jupyter Notebook-based tutorials without using Docker, do the following:

  1. Clone the Apache Druid repo, or download the tutorials as well as the Python client for Druid.

  2. Install the prerequisite Python packages with the following commands:

    # Install requests
    pip install requests
    
    # Install JupyterLab
    pip install jupyterlab
    
    # Install Jupyter Notebook
    pip install notebook
    

    Individual notebooks may list additional packages you need to install to complete the tutorial.

  3. In your Druid source repo, install druidapi with the following commands:

    cd examples/quickstart/jupyter-notebooks/druidapi
    pip install .
    
  4. Start Jupyter, in the same directory as the tutorials, using either JupyterLab or Jupyter Notebook:

    # Start JupyterLab on port 3001
    jupyter lab --port 3001
    
    # Start Jupyter Notebook on port 3001
    jupyter notebook --port 3001
    
  5. Start Druid. You can use the Quickstart (local) instance. The tutorials assume that you are using the quickstart, so no authentication or authorization is expected unless explicitly mentioned.

    If you contribute to Druid, and work with Druid integration tests, you can use a test cluster. Assume you have an environment variable, DRUID_DEV, which identifies your Druid source repo.

    cd $DRUID_DEV
    ./it.sh build
    ./it.sh image
    ./it.sh up <category>
    

    Replace <category> with one of the available integration test categories. See the integration test README.md for details.

You should now be able to access and complete the tutorials.

Tutorial setup for ARM-based devices

For ARM-based devices, follow this setup to start Druid externally, while keeping Kafka and Jupyter within the Docker Compose environment:

  1. Start Druid using the start-druid script. You can follow Quickstart (local) instructions. The tutorials assume that you are using the quickstart, so no authentication or authorization is expected unless explicitly mentioned.

  2. Start either Jupyter only or Jupyter and Kafka using the following commands in the same directory as docker-compose.yaml and environment:

    # Start only Jupyter
    docker compose --profile jupyter up -d
    
    # Start Kafka and Jupyter
    DRUID_VERSION={{DRUIDVERSION}} docker compose --profile kafka-jupyter up -d
    
  3. If Druid is running local to the same machine as Jupyter, open the tutorial and set the host variable to host.docker.internal before starting. For example:

    host = "host.docker.internal"
    
  4. If using Kafka to handle the data stream that will be ingested into Druid and Druid is running local to the same machine, update the consumer property bootstrap.servers to localhost:9094.

Learn more

See the following topics for more information:

  • Jupyter Notebook tutorials for the available Jupyter Notebook-based tutorials for Druid
  • Tutorial: Run with Docker for running Druid from a Docker container
← Jupyter Notebook tutorialsJDBC connector →
  • Prerequisites
  • Launch the Docker containers
    • Start only the Jupyter container
    • Start Jupyter and Druid
    • Start Jupyter, Druid, and Kafka
    • Start Kafka and Jupyter
    • Update image from Docker Hub
    • Use locally built image
  • Access Jupyter-based tutorials
  • View the Druid web console
  • Stop Docker containers
  • Tutorial setup without using Docker
  • Tutorial setup for ARM-based devices
  • Learn more

Technology · Use Cases · Powered by Druid · Docs · Community · Download · FAQ

 ·  ·  · 
Copyright © 2022 Apache Software Foundation.
Except where otherwise noted, licensed under CC BY-SA 4.0.
Apache Druid, Druid, and the Druid logo are either registered trademarks or trademarks of The Apache Software Foundation in the United States and other countries.