Package io.kestra.plugin.jdbc.pinot

Class Query

java.lang.Object
io.kestra.core.models.tasks.Task
io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
io.kestra.plugin.jdbc.AbstractJdbcQuery
io.kestra.plugin.jdbc.pinot.Query
All Implemented Interfaces:
io.kestra.core.models.Plugin, io.kestra.core.models.PluginVersioning, io.kestra.core.models.tasks.RunnableTask<io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.Output>, io.kestra.core.models.tasks.TaskInterface, io.kestra.core.models.WorkerJobLifecycle, io.kestra.plugin.jdbc.JdbcConnectionInterface, io.kestra.plugin.jdbc.JdbcQueryInterface, io.kestra.plugin.jdbc.JdbcStatementInterface, PinotConnectionInterface
@Plugin(examples=@Example(full=true,code="id: pinot_query\nnamespace: company.team\n\ntasks:\n - id: query\n type: io.kestra.plugin.jdbc.pinot.Query\n url: jdbc:pinot://localhost:9000\n username: \"{{ secret(\'PINOT_USERNAME\') }}\"\n password: \"{{ secret(\'PINOT_PASSWORD\') }}\"\n sql: |\n SELECT *\n FROM airlineStats\n WHERE __time >= 1672531200000 -- 2023-01-01T00:00:00Z in millis\n fetchType: FETCH\n"), metrics=@Metric(name="fetch.size",type="counter",unit="rows",description="The number of fetched rows.")) public class Query extends io.kestra.plugin.jdbc.AbstractJdbcQuery implements PinotConnectionInterface

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.kestra.plugin.jdbc.AbstractJdbcQuery

    io.kestra.plugin.jdbc.AbstractJdbcQuery.AbstractJdbcQueryBuilder<C extends io.kestra.plugin.jdbc.AbstractJdbcQuery,B extends io.kestra.plugin.jdbc.AbstractJdbcQuery.AbstractJdbcQueryBuilder<C,B>>

    Nested classes/interfaces inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.AbstractJdbcBaseQueryBuilder<C extends io.kestra.plugin.jdbc.AbstractJdbcBaseQuery,B extends io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.AbstractJdbcBaseQueryBuilder<C,B>>, io.kestra.plugin.jdbc.AbstractJdbcBaseQuery.Output

    Nested classes/interfaces inherited from class io.kestra.core.models.tasks.Task

    io.kestra.core.models.tasks.Task.TaskBuilder<C extends io.kestra.core.models.tasks.Task,B extends io.kestra.core.models.tasks.Task.TaskBuilder<C,B>>

  • Field Summary

    Fields inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    additionalVars, afterSQL, fetchSize, fetchType, outputFiles, parameters, sql

    Fields inherited from class io.kestra.core.models.tasks.Task

    disabled, id, retry, timeout, type, version

    Fields inherited from interface io.kestra.core.models.PluginVersioning

    DESCRIPTION, TITLE

  • Constructor Summary

    Constructors
    Constructor
    Description
    Query()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected Statement
    createStatement(Connection conn)
     
    protected io.kestra.plugin.jdbc.AbstractCellConverter
    getCellConverter(ZoneId zoneId)
     
    protected Integer
    getFetchSize(io.kestra.core.runners.RunContext runContext)
     
    void
    registerDriver()
     

    Methods inherited from class io.kestra.plugin.jdbc.AbstractJdbcQuery

    beforeExecute, canEqual, equals, hashCode, kill, run, toString

    Methods inherited from class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    createPreparedStatement, fetch, fetchResult, fetchResults, fetchToFile, getAfterSQL, getConnectionPooling, getConnectionPoolSize, getFetchSize, getFetchType, getOutputFiles, getParameters, getPassword, getSql, getTimeZoneId, getUrl, getUsername, isFetch, isFetchOne, isStore, kill, kill, mapResultSetToMap, prepareStatement, renderFetchType, supportsMultiStatements, tags, upsertAsset

    Methods inherited from class io.kestra.core.models.tasks.Task

    findById, findById, getAssets, getDescription, getDisabled, getId, getLogLevel, getRetry, getRunIf, getTaskCache, getTimeout, getType, getVersion, getWorkerGroup, isAllowFailure, isAllowWarning, isFlowable, isLogToFile, isSendToWorkerTask

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface io.kestra.plugin.jdbc.JdbcConnectionInterface

    connection, connectionProperties, connectionProperties, getConnectionPooling, getConnectionPoolSize, getPassword, getUrl, getUsername, usesConnectionPool, validateUrl

    Methods inherited from interface io.kestra.plugin.jdbc.JdbcStatementInterface

    zoneId

    Methods inherited from interface io.kestra.plugin.jdbc.pinot.PinotConnectionInterface

    getScheme

    Methods inherited from interface io.kestra.core.models.WorkerJobLifecycle

    stop

  • Constructor Details

    • Query

      public Query()

  • Method Details

    • getCellConverter

      protected io.kestra.plugin.jdbc.AbstractCellConverter getCellConverter(ZoneId zoneId)
      Specified by:
      getCellConverter in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery

    • registerDriver

      public void registerDriver() throws SQLException
      Specified by:
      registerDriver in interface io.kestra.plugin.jdbc.JdbcConnectionInterface
      Throws:
      SQLException

    • createStatement

      protected Statement createStatement(Connection conn) throws SQLException
      Overrides:
      createStatement in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
      Throws:
      SQLException

    • getFetchSize

      protected Integer getFetchSize(io.kestra.core.runners.RunContext runContext) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      getFetchSize in class io.kestra.plugin.jdbc.AbstractJdbcBaseQuery
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException