Query
Certified
Execute a SQL query using Apache Arrow Flight SQL
Query
Certified
Execute a SQL query using Apache Arrow Flight SQL
yaml
type: io.kestra.plugin.jdbc.arrowflight.QueryExamples
yaml
id: arrow_flight_sql_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.jdbc.arrowflight.Query
url: jdbc:arrow-flight-sql://localhost:31010/?useEncryption=false
username: "{{ secret('ARROWFLIGHT_USERNAME') }}"
password: "{{ secret('ARROWFLIGHT_PASSWORD') }}"
sql: SELECT * FROM departments
fetchType: FETCH
yaml
id: arrow_flight_sql_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.jdbc.arrowflight.Query
url: jdbc:arrow-flight-sql://dremio-coordinator:32010/?schema=postgres.public&useEncryption=false
username: "{{ secret('DREMIO_USERNAME') }}"
password: "{{ secret('DREMIO_PASSWORD') }}"
sql: SELECT * FROM departments
fetchType: FETCH
Properties
sql *Requiredstring
url *Requiredstring
afterSQL string
fetchSize integerstring
Default
10000fetchType string
Default
NONEPossible Values
STOREFETCHFETCH_ONENONEoutputFiles array
SubTypestring
parameters object
password string
timeZoneId string
username string
Outputs
row object
rows array
SubTypeobject
size integer
uri string
Format
uriMetrics
fetch.size counter
Unit
rows
