Partitioning
You can use segment partitioning and sorting within your Druid datasources to reduce the size of your data and increase performance.
One way to partition is to load data into separate datasources. This is a perfectly viable approach that works very well when the number of datasources does not lead to excessive per-datasource overheads.
This topic describes how to set up partitions within a single datasource. It does not cover how to use multiple datasources. See Multitenancy considerations for more details on splitting data into separate datasources and potential operational considerations.
Time chunk partitioning
Druid always partitions datasources by time into time chunks. Each time chunk contains one or more segments. This partitioning happens for all ingestion methods based on the segmentGranularity
parameter in your ingestion spec dataSchema
object.
Partitioning by time is important for two reasons:
- Queries that filter by
__time
(SQL) orintervals
(native) are able to use time partitioning to prune the set of segments to consider. - Certain data management operations, such as overwriting and compacting existing data, acquire exclusive write locks on time partitions.
- Each segment file is wholly contained within a time partition. Too-fine-grained partitioning may cause a large number of small segments, which leads to poor performance.
The most common choices to balance these considerations are hour
and day
. For streaming ingestion, hour
is especially
common, because it allows compaction to follow ingestion with less of a time delay.
The following table describes how to configure time chunk partitioning.
Method | Configuration |
---|---|
SQL | PARTITIONED BY |
Kafka or Kinesis | segmentGranularity inside the granularitySpec |
Native batch or Hadoop | segmentGranularity inside the granularitySpec |
Secondary partitioning
Druid further partitions each time chunk into immutable segments. Secondary partitioning on a particular dimension improves locality. This means that rows with the same value for that dimension are stored together, decreasing access time.
To achieve the best performance and smallest overall footprint, partition your data on a "natural" dimension that you often use as a filter, or that achieves some alignment within your data. Such partitioning can improve compression and query performance by significant multiples.
The following table describes how to configure secondary partitioning.
Method | Configuration |
---|---|
SQL | CLUSTERED BY |
Kafka or Kinesis | Upstream partitioning defines how Druid partitions the datasource. You can also alter clustering using REPLACE (with CLUSTERED BY ) or compaction after initial ingestion. |
Native batch or Hadoop | partitionsSpec inside the tuningConfig |
Sorting
Each segment is internally sorted to promote compression and locality.
Partitioning and sorting work well together. If you do have a "natural" partitioning dimension, consider placing it first in your sort order as well. This way, Druid sorts rows within each segment by that column. This sorting configuration frequently improves compression and performance more than using partitioning alone.
The following table describes how to configure sorting.
Method | Configuration |
---|---|
SQL | Uses order of fields in CLUSTERED BY or segmentSortOrder in the query context |
Kafka or Kinesis | Uses order of fields in dimensionsSpec |
Native batch or Hadoop | Uses order of fields in dimensionsSpec |
Druid implicitly sorts rows within a segment by __time
first before any dimensions
or CLUSTERED BY
fields, unless
you set forceSegmentSortByTime
to false
in your
query context (for SQL) or in your
dimensionsSpec
(for other ingestion forms).
Setting forceSegmentSortByTime
to false
is an experimental feature. Segments created with sort orders that
do not start with __time
can only be read by Druid 31 or later. Additionally, at this time, certain queries are not
supported on such segments, including:
- Native queries with
granularity
other thanall
. - Native
scan
query with ascending or descending time order. - SQL queries that plan into an unsupported native query.
Learn more
See the following topics for more information:
partitionsSpec
for more detail on partitioning with Native Batch ingestion.- Reindexing and Compaction for information on how to repartition existing data in Druid.