Query

Query

Certified

Execute a SQL query against Apache Pinot

yaml
type: io.kestra.plugin.jdbc.pinot.Query
yaml
id: pinot_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.jdbc.pinot.Query
    url: jdbc:pinot://localhost:9000
    username: "{{ secret('PINOT_USERNAME') }}"
    password: "{{ secret('PINOT_PASSWORD') }}"
    sql: |
      SELECT *
      FROM airlineStats
      WHERE __time >= 1672531200000 -- 2023-01-01T00:00:00Z in millis
    fetchType: FETCH
Properties
Default10000
DefaultNONE
Possible Values
STOREFETCHFETCH_ONENONE
SubTypeobject
Formaturi
Unitrows