Apache Druid · Schema

IngestionTask

An Apache Druid data ingestion task for batch or streaming data loading.

AnalyticsApacheDatabaseKafkaOLAPOpen SourceReal-TimeSQLTime Series

Properties

Name	Type	Description
id	string	Unique task ID assigned by Druid.
type	string	Task type identifier.
dataSource	string	Target datasource name.
groupId	string	Task group ID for parallel tasks.
status	string	Current task status.
createdTime	string	Task creation timestamp.
queueInsertionTime	string	Task queue insertion timestamp.
location	object	Host and port where this task is running.
duration	integer	Task duration in milliseconds (-1 if still running).

View JSON Schema on GitHub

JSON Schema

{
  "$schema": "https://json-schema.org/draft/2020-12/schema",
  "$id": "https://raw.githubusercontent.com/api-evangelist/apache-druid/refs/heads/main/json-schema/apache-druid-ingestion-task-schema.json",
  "title": "IngestionTask",
  "description": "An Apache Druid data ingestion task for batch or streaming data loading.",
  "type": "object",
  "properties": {
    "id": {
      "type": "string",
      "description": "Unique task ID assigned by Druid.",
      "example": "index_kafka_wikipedia_abc123_0"
    },
    "type": {
      "type": "string",
      "description": "Task type identifier.",
      "enum": [
        "index",
        "index_parallel",
        "index_kafka",
        "index_kinesis",
        "compact",
        "kill"
      ],
      "example": "index_parallel"
    },
    "dataSource": {
      "type": "string",
      "description": "Target datasource name.",
      "example": "wikipedia"
    },
    "groupId": {
      "type": "string",
      "description": "Task group ID for parallel tasks.",
      "example": "index_parallel_wikipedia_abc123"
    },
    "status": {
      "type": "string",
      "description": "Current task status.",
      "enum": [
        "WAITING",
        "PENDING",
        "RUNNING",
        "SUCCESS",
        "FAILED"
      ],
      "example": "RUNNING"
    },
    "createdTime": {
      "type": "string",
      "format": "date-time",
      "description": "Task creation timestamp.",
      "example": "2025-03-15T14:30:00Z"
    },
    "queueInsertionTime": {
      "type": "string",
      "format": "date-time",
      "description": "Task queue insertion timestamp.",
      "example": "2025-03-15T14:30:05Z"
    },
    "location": {
      "type": "object",
      "description": "Host and port where this task is running.",
      "properties": {
        "host": {
          "type": "string",
          "example": "druid-worker-01"
        },
        "port": {
          "type": "integer",
          "example": 8100
        }
      }
    },
    "duration": {
      "type": "integer",
      "description": "Task duration in milliseconds (-1 if still running).",
      "example": -1
    }
  }
}