Query

yaml
type: "io.kestra.plugin.jdbc.druid.Query"

Examples

yaml
id: druid_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.druid.Query
    url: jdbc:avatica:remote:url=http://localhost:8888/druid/v2/sql/avatica/;transparent_reconnection=true
    sql: |
      SELECT *
      FROM wikiticker
    fetchType: STORE

Properties

sql*string

url*string

afterSQLstring

fetchSizeintegerstring

Default10000

fetchTypestring

DefaultNONE

Possible Values

STOREFETCHFETCH_ONENONE

parametersobject

passwordstring

timeZoneIdstring

usernamestring

Outputs

rowobject

rowsarray

SubTypeobject

sizeinteger

uristring

Formaturi

Metrics

fetch.sizecounter

Unitrows

Query

Create automations with Jdbc Druid Query

Fetch data from Apache Druid and transform it in Python with Pandas

Query data from Druid and load it to Redshift